export declare class KafkaProducer {
    private clientId;
    private brokers;
    private producer;
    constructor(clientId: string, brokers: string[]);
    connect(): Promise<void>;
    send(topic: string, messages: any[]): Promise<void>;
    disconnect(): Promise<void>;
}