| 1 | /// <reference types="node" />
|
| 2 | import { Serializer } from '../interfaces/serializer.interface';
|
| 3 | export interface KafkaRequest<T = any> {
|
| 4 | key: Buffer | string | null;
|
| 5 | value: T;
|
| 6 | headers: Record<string, any>;
|
| 7 | }
|
| 8 | /**
|
| 9 | * @publicApi
|
| 10 | */
|
| 11 | export declare class KafkaRequestSerializer implements Serializer<any, KafkaRequest | Promise<KafkaRequest>> {
|
| 12 | serialize(value: any): any;
|
| 13 | encode(value: any): Buffer | string | null;
|
| 14 | }
|