import { OnModuleInit, OnModuleDestroy } from '@nestjs/common';
import { ConfigService } from '@nestjs/config';
export declare class ProducerService implements OnModuleInit, OnModuleDestroy {
    private configService;
    private readonly kafka;
    private readonly producer;
    private readonly logger;
    constructor(configService: ConfigService);
    onModuleInit(): Promise<void>;
    onModuleDestroy(): Promise<void>;
    sendMessage(topic: string, message: any, key?: string, headers?: Record<string, string>): Promise<import("kafkajs").RecordMetadata[]>;
    sendBatchMessages(topic: string, messages: any[], keys?: string[]): Promise<import("kafkajs").RecordMetadata[]>;
}