import type { IBrokerMessageRoutingOptions, IMessageBrokerService } from '../../types';
export declare class KafkaService implements IMessageBrokerService {
    private config;
    private kafka;
    private producer;
    private consumer;
    private readonly logPrefix;
    constructor(config: {
        brokers: string[];
        clientId: string;
        groupId?: string;
        ssl?: boolean;
        sasl?: {
            mechanism: 'plain' | 'scram-sha-256' | 'scram-sha-512';
            username: string;
            password: string;
        };
    });
    connect(): Promise<void>;
    publish(topic: string, message: object, options?: IBrokerMessageRoutingOptions): Promise<void>;
    subscribe(topic: string, callback: (message: object) => Promise<void>, options?: IBrokerMessageRoutingOptions): Promise<void>;
    disconnect(): Promise<void>;
}