Function getKafka

packages/queue/src/kafka.ts:86–102

()

let kafka: Kafka | null = null;
const getKafka = (): Kafka => {
  if (!isKafkaConfigured()) {
    throw new Error(
      'KAFKA_BROKERS env var is not set; cannot create Kafka client'
    );
  }
  if (!kafka) {
    kafka = new Kafka({
      clientId: process.env.KAFKA_CLIENT_ID || 'openpanel',
      brokers: KAFKA_BROKERS,
      logLevel: logLevel.WARN,
      requestTimeout: KAFKA_REQUEST_TIMEOUT_MS,
      connectionTimeout: KAFKA_CONNECTION_TIMEOUT_MS,
    });
  }
  return kafka;
};

let producer: Producer | null = null;
let producerConnectPromise: Promise<Producer> | null = null;