import { EachMessagePayload } from "kafkajs";
export declare class KafkaConsumer {
    private clientId;
    private brokers;
    private groupId;
    private consumer;
    constructor(clientId: string, brokers: string[], groupId: string);
    connect(topic: string, onMessage: (message: EachMessagePayload) => Promise<void>): Promise<void>;
    disconnect(): Promise<void>;
}