import { ProducerBatch, ProducerConfig, ProducerRecord } from 'kafkajs';
export interface KafkaProduceRecord extends Omit<ProducerRecord, 'topic' | 'messages'> {
    producerKey?: string;
}
export interface KafkaProduceConfig extends ProducerConfig {
}
export interface KafkaProducerOptions {
    record?: KafkaProduceRecord;
    config?: KafkaProduceConfig;
}
export interface KafkaProduceDecoratorOptions extends KafkaProducerOptions {
    useEnv?: boolean;
}
export interface KafkaProduceBatch extends ProducerBatch {
    producerKey: string;
}
export interface KafkaProduceBatchOptions {
    config?: KafkaProduceConfig;
}
//# sourceMappingURL=kafka-producer.model.d.ts.map