Function isKafkaConfigured

packages/queue/src/kafka.ts:81–81

()

  KAFKA_MAX_MESSAGES_PER_PARTITION * KAFKA_BYTES_PER_MESSAGE;

export const isKafkaConfigured = (): boolean => KAFKA_BROKERS.length > 0;

export const shouldUseKafka = (): boolean => isKafkaConfigured();