kafkaClient = new Kafka({
      clientId: 'collect-data',
      brokers: [
        `${process.env.PREDECOS_KAFKA_HOST}:${process.env.PREDECOS_KAFKA_PORT}`,
      ],