/// <reference types="node" />
import { EventEmitter } from 'events';
import * as KafkaJS from 'kafkajs';
/**
 * @hidden
 * Kafka client abstract class
 */
export declare abstract class KafkaClient extends EventEmitter {
    protected readonly kafka: KafkaJS.Kafka;
    protected isReady: boolean;
    /**
     * Instantiates a new Kafka client
     *
     * @param brokers - List of brokers to connect to
     * @param kafkaConfig - Kafka client configuration
     */
    protected constructor(kafkaConfig: KafkaJS.KafkaConfig);
    /**
     * Returns true if the Producer is ready to produce messages
     */
    ready(): boolean;
}