import { KafkaConfig, Producer, ProducerConfig } from 'kafkajs';
export declare function createKafkaProducer(options: {
    kafkaConfig: KafkaConfig;
    producerConfig?: ProducerConfig;
    mock?: boolean;
}): Promise<Producer>;
//# sourceMappingURL=kafka.d.ts.map