const kafka = new Kafka({
    clientId: 'deep-microservice-collection',
    brokers: [
      `${process.env.PREDECOS_KAFKA_HOST}:${process.env.PREDECOS_KAFKA_PORT}`,
    ],