import { KafkaService } from './kafka.service';
import { CryptoService } from '../core/crypto.service';
export declare class KafkaController {
    private readonly kafkaService;
    private readonly cryptoService;
    constructor(kafkaService: KafkaService, cryptoService: CryptoService);
    handleTestMessage(message: any): Promise<any>;
    handleBatchMessage(message: any): Promise<any>;
    handleErrorMessage(message: any): Promise<any>;
    handlePerformanceMessage(message: any): Promise<any>;
}