Enterprise-CMCS/macpro-appian-connector

Function createTopics has 65 lines of code (exceeds 40 allowed). Consider refactoring.

Open

export async function createTopics(brokerString, topicsConfig) {
  const topics = topicsConfig;
  const brokers = brokerString.split(",");

  const kafka = new Kafka({

Function create has 54 lines of code (exceeds 40 allowed). Consider refactoring.

Open

  const create = async () => {
    await admin.connect();

    //fetch topics from MSK and filter out __ internal management topic
    const existingTopicList = _.filter(await admin.listTopics(), function (n) {

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    const paritionConfig = _.map(topicsToUpdate, function (topic) {
      return {
        topic: _.get(topic, "topic"),
        count: _.get(topic, "numPartitions"),
      };

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    const configOptions = _.map(topicsMetadata, function (topic) {
      return {
        name: _.get(topic, "name"),
        type: _.get(ResourceTypes, "TOPIC"),
      };

• Read up
  Read up