import { CryptoService } from '../core/crypto.service';
export declare class EnhancedKafkaService {
    private readonly cryptoService;
    constructor(cryptoService: CryptoService);
    encryptKafkaMessage(message: any, key: Buffer): Promise<Buffer>;
    decryptKafkaMessage(encryptedMessage: Buffer, key: Buffer): Promise<any>;
    encryptKafkaMessages(messages: any[], key: Buffer): Promise<Buffer[]>;
    decryptKafkaMessages(encryptedMessages: Buffer[], key: Buffer): Promise<any[]>;
    encryptSensitiveKafkaMessage(message: any): Promise<{
        ciphertext: Buffer;
        encapsulatedKey: Buffer;
    }>;
    decryptSensitiveKafkaMessage(ciphertext: Buffer, encapsulatedKey: Buffer, privateKey: Buffer): Promise<any>;
}