import { KafkaMessage } from 'kafkajs';
import { IKafkaEvent, IKafkaModuleSchemaRegistryConfiguration } from '../interfaces';
import { KafkaLogger } from '../loggers';
export declare class KafkaDeserializer {
    private readonly kafkaLogger;
    private schemaRegistry;
    constructor(kafkaLogger: KafkaLogger);
    initialize(configuration: IKafkaModuleSchemaRegistryConfiguration, randomSubject?: string): Promise<void>;
    deserialize(message: KafkaMessage): Promise<IKafkaEvent>;
}