import { IPatternDTO, IMessageOptionsDTO, IWritePacketDTO, IReadPacketDTO, Proxy } from 'cross-proxy';
import { Message, Producer, RecordMetadata } from 'kafkajs';
import { IConsumerAssignmentDTO } from '../interfaces/IConsumerAssignmentDTO.js';
import { IKafkaConfigDTO } from '../interfaces/IKafkaConfigDTO.js';
export declare abstract class KafkaCore extends Proxy<Omit<Message, 'value'>> {
    private readonly consumerAssignments;
    private readonly responsePatterns;
    private readonly config;
    private initialized;
    private producer;
    private consumer;
    private client;
    private readonly defaults;
    constructor(config?: IKafkaConfigDTO);
    protected getConsumerAssignments(): IConsumerAssignmentDTO;
    protected connect(): Promise<Producer>;
    protected closeConnections(): Promise<void>;
    protected subscribe(pattern: IPatternDTO): void;
    protected serializeMessageOptions(options?: IMessageOptionsDTO): Omit<Message, 'value'>;
    protected deserializeMessage<Input>(value: Input, message: Message): IWritePacketDTO<Input> & {
        id: string;
    };
    protected decode<Input, Val>(value: Val): Input | string | null | Buffer;
    protected setListener<T, X>({ handlers, pattern, }: {
        pattern: IPatternDTO;
        handlers: Array<(data: IWritePacketDTO<T>) => X>;
    }): void;
    protected publish<Input, Output>({ callback, partialPacket, }: {
        partialPacket: IReadPacketDTO<Input, IMessageOptionsDTO>;
        callback: (packet: IWritePacketDTO<Output>) => void;
    }): () => void | undefined;
    protected dispatchEvent<Input>(packet: IReadPacketDTO<Input, IMessageOptionsDTO>): Promise<Array<RecordMetadata>>;
    private createClient;
    private createResponseCallback;
    private setConsumerAssignments;
    private getReplyTopicPartition;
    private getResponsePatternName;
    private bindTopics;
    private serialize;
    private parse;
    private encode;
}