import { OnModuleInit, OnModuleDestroy, Logger } from '@nestjs/common';
import { ICustomPartitioner, KafkaConfig, ProducerRecord } from 'kafkajs';
export declare class KafkaProducerService implements OnModuleInit, OnModuleDestroy {
    readonly createPartitioner: ICustomPartitioner;
    private readonly options;
    readonly logger: Logger;
    private kafka;
    private producer;
    constructor(createPartitioner: ICustomPartitioner, options: KafkaConfig);
    onModuleInit(): Promise<void>;
    send(payload: ProducerRecord): Promise<void>;
    onModuleDestroy(): Promise<void>;
}