import { Consumer, Kafka, Producer } from 'kafkajs';

declare function getKafka(): Promise<Kafka>;
declare function getProducer(): Promise<Producer>;
declare function getConsumer(): Promise<Consumer>;
declare function disconnectKafka(): Promise<void>;

export { disconnectKafka, getConsumer, getKafka, getProducer };