/// <reference types="node" />
import { Serializer } from '../interfaces/serializer.interface';
export interface KafkaRequest<T = any> {
key: Buffer | string | null;
value: T;
headers: Record<string, any>;
}
export declare class KafkaRequestSerializer implements Serializer<any, KafkaRequest> {
serialize(value: any): KafkaRequest;
encode(value: any): Buffer | string | null;
}