File kafka.ts

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

import { createLogger } from '@openpanel/logger';
import { type Consumer, Kafka, logLevel, type Producer } from 'kafkajs';
import type { EventsQueuePayloadIncomingEvent } from './queues';