Function resetProducer

packages/queue/src/kafka.ts:172–184

(broken: Producer)

};

const resetProducer = (broken: Producer): void => {
  if (producer !== broken) {
    return;
  }
  producer = null;
  producerConnectPromise = null;
  broken.disconnect().catch((err) => {
    kafkaLogger.warn(
      { err },
      'kafka producer disconnect after fatal error failed'
    );
  });
};

export const produceIncomingEvent = async (
  payload: EventsQueuePayloadIncomingEvent['payload'],