import { Logger } from '@nestjs/common/services/logger.service'; import { KafkaContext } from '../ctx-host'; import { Transport } from '../enums'; import { BrokersFunction, Consumer, EachMessagePayload, Kafka, Message, Producer, RecordMetadata } from '../external/kafka.interface'; import { KafkaParser } from '../helpers'; import { CustomTransportStrategy, KafkaOptions, OutgoingResponse, ReadPacket } from '../interfaces'; import { Server } from './server'; /** * @publicApi */ export declare class ServerKafka extends Server implements CustomTransportStrategy { protected readonly options: KafkaOptions['options']; readonly transportId = Transport.KAFKA; protected logger: Logger; protected client: Kafka; protected consumer: Consumer; protected producer: Producer; protected parser: KafkaParser; protected brokers: string[] | BrokersFunction; protected clientId: string; protected groupId: string; constructor(options: KafkaOptions['options']); listen(callback: (err?: unknown, ...optionalParams: unknown[]) => void): Promise; close(): Promise; start(callback: () => void): Promise; createClient(): T; bindEvents(consumer: Consumer): Promise; getMessageHandler(): (payload: EachMessagePayload) => Promise; getPublisher(replyTopic: string, replyPartition: string, correlationId: string): (data: any) => Promise; handleMessage(payload: EachMessagePayload): Promise; private combineStreamsAndThrowIfRetriable; sendMessage(message: OutgoingResponse, replyTopic: string, replyPartition: string, correlationId: string): Promise; assignIsDisposedHeader(outgoingResponse: OutgoingResponse, outgoingMessage: Message): void; assignErrorHeader(outgoingResponse: OutgoingResponse, outgoingMessage: Message): void; assignCorrelationIdHeader(correlationId: string, outgoingMessage: Message): void; assignReplyPartition(replyPartition: string, outgoingMessage: Message): void; handleEvent(pattern: string, packet: ReadPacket, context: KafkaContext): Promise; protected initializeSerializer(options: KafkaOptions['options']): void; protected initializeDeserializer(options: KafkaOptions['options']): void; }