import { OnModuleInit, OnModuleDestroy } from '@nestjs/common';
import { ClientKafka } from '@nestjs/microservices';
import { CryptoService } from '../core/crypto.service';
export declare class KafkaService implements OnModuleInit, OnModuleDestroy {
    private readonly cryptoService;
    private readonly client;
    private readonly logger;
    private readonly topics;
    private readonly isTestEnv;
    private logError;
    constructor(cryptoService: CryptoService, client: ClientKafka);
    onModuleInit(): Promise<void>;
    onModuleDestroy(): Promise<void>;
    sendMessage<T = unknown>(topic: string, message: unknown, key: Buffer): Promise<T>;
    sendBatch<T = unknown>(topic: string, messages: unknown[], key: Buffer): Promise<T[]>;
    sendInvalidMessage<T = unknown>(): Promise<T>;
    runPerformanceTest<T = unknown>(messageCount: number, key: Buffer): Promise<T[]>;
}