class ClientKafka extends ClientProxy implements ClientKafkaProxy {
  constructor(options: { postfixId?: string; client?: KafkaConfig; consumer?: ConsumerConfig; run?: Omit<ConsumerRunConfig, "eachBatch" | "eachMessage">; ... 6 more ...; producerOnlyMode?: boolean; })
  protected logger: Logger
  protected client: Kafka | null
  protected parser: KafkaParser | null
  protected initialized: Promise<void> | null
  protected responsePatterns: string[]
  protected consumerAssignments: {...}
  protected brokers: string[] | BrokersFunction
  protected clientId: string
  protected groupId: string
  protected producerOnlyMode: boolean
  protected _consumer: Consumer | null
  protected _producer: Producer | null
  consumer: Consumer
  producer: Producer
  protected options: Required<KafkaOptions>['options']
  subscribeToResponseOf(pattern: unknown): void
  close(): Promise<void>
  connect(): Promise<Producer>
  bindTopics(): Promise<void>
  createClient<T = any>(): T
  createResponseCallback(): (payload: EachMessagePayload) => any
  getConsumerAssignments()
  emitBatch<TResult = any, TInput = any>(pattern: any, data: { messages: TInput[]; }): Observable<TResult>
  commitOffsets(topicPartitions: TopicPartitionOffsetAndMetadata[]): Promise<void>
  unwrap<T>(): T
  on<EventKey extends string | number | symbol = string | number | symbol, EventCallback = any>(event: EventKey, callback: EventCallback)
  protected registerConsumerEventListeners()
  protected registerProducerEventListeners()
  protected dispatchBatchEvent<TInput = any>(packets: ReadPacket<{ messages: TInput[]; }>): Promise<any>
  protected dispatchEvent(packet: OutgoingEvent): Promise<any>
  protected getReplyTopicPartition(topic: string): string
  protected publish(partialPacket: ReadPacket<any>, callback: (packet: WritePacket<any>) => any): () => void
  protected getResponsePatternName(pattern: string): string
  protected setConsumerAssignments(data: ConsumerGroupJoinEvent): void
  protected initializeSerializer(options: { postfixId?: string; client?: KafkaConfig; consumer?: ConsumerConfig; run?: Omit<ConsumerRunConfig, "eachBatch" | "eachMessage">; ... 6 more ...; producerOnlyMode?: boolean; })
  protected initializeDeserializer(options: { postfixId?: string; client?: KafkaConfig; consumer?: ConsumerConfig; run?: Omit<ConsumerRunConfig, "eachBatch" | "eachMessage">; ... 6 more ...; producerOnlyMode?: boolean; })

  // inherited from nest/packages/microservices/ClientProxy
  protected routingMap: Map<string, Function>
  protected serializer: ProducerSerializer
  protected deserializer: ProducerDeserializer
  protected _status$: ReplaySubject<Status>
  status: Observable<Status>
  abstract connect(): Promise<any>
  abstract close(): any
  on<EventKey extends keyof EventsMap = keyof EventsMap, EventCallback extends EventsMap[EventKey] = EventsMap[EventKey]>(event: EventKey, callback: EventCallback)
  abstract unwrap<T>(): T
  send<TResult = any, TInput = any>(pattern: any, data: TInput): Observable<TResult>
  emit<TResult = any, TInput = any>(pattern: any, data: TInput): Observable<TResult>
  protected abstract publish(packet: ReadPacket<any>, callback: (packet: WritePacket<any>) => void): () => void
  protected abstract dispatchEvent<T = any>(packet: ReadPacket<any>): Promise<T>
  protected createObserver<T>(observer: Observer<T>): (packet: WritePacket) => void
  protected serializeError(err: any): any
  protected serializeResponse(response: any): any
  protected assignPacketId(packet: ReadPacket<any>): ReadPacket & PacketId
  protected connect$(instance: any, errorEvent: string = 'error', connectEvent: string = 'connect'): Observable<any>
  protected getOptionsProp<Options extends ClientOptions['options'], Attribute extends keyof Options, DefaultValue extends Options[Attribute] = Options[Attribute]>(obj: Options, prop: Attribute, defaultValue: DefaultValue = undefined as DefaultValue)
  protected normalizePattern(pattern: MsPattern): string
  protected initializeSerializer(options: { url?: string; maxSendMessageLength?: number; maxReceiveMessageLength?: number; maxMetadataSize?: number; keepalive?: { keepaliveTimeMs?: number; keepaliveTimeoutMs?: number; keepalivePermitWithoutCalls?: number; http2MaxPingsWithoutData?: number; http2MinTimeBetweenPingsMs?: number; http2MinPingIntervalWithoutData...)
  protected initializeDeserializer(options: { url?: string; maxSendMessageLength?: number; maxReceiveMessageLength?: number; maxMetadataSize?: number; keepalive?: { keepaliveTimeMs?: number; keepaliveTimeoutMs?: number; keepalivePermitWithoutCalls?: number; http2MaxPingsWithoutData?: number; http2MinTimeBetweenPingsMs?: number; http2MinPingIntervalWithoutData...)
}

Constructor

constructor(options: { postfixId?: string; client?: KafkaConfig; consumer?: ConsumerConfig; run?: Omit<ConsumerRunConfig, "eachBatch" | "eachMessage">; ... 6 more ...; producerOnlyMode?: boolean; })

subscribeToResponseOf(pattern: unknown): void

close(): Promise<void>

connect(): Promise<Producer>

bindTopics(): Promise<void>

createClient<T = any>(): T

createResponseCallback(): (payload: EachMessagePayload) => any

getConsumerAssignments()

emitBatch<TResult = any, TInput = any>(pattern: any, data: { messages: TInput[]; }): Observable<TResult>

commitOffsets(topicPartitions: TopicPartitionOffsetAndMetadata[]): Promise<void>

unwrap<T>(): T

on<EventKey extends string | number | symbol = string | number | symbol, EventCallback = any>(event: EventKey, callback: EventCallback)

protected registerConsumerEventListeners()

protected registerProducerEventListeners()

protected dispatchBatchEvent<TInput = any>(packets: ReadPacket<{ messages: TInput[]; }>): Promise<any>

protected dispatchEvent(packet: OutgoingEvent): Promise<any>

protected getReplyTopicPartition(topic: string): string

protected publish(partialPacket: ReadPacket<any>, callback: (packet: WritePacket<any>) => any): () => void

protected getResponsePatternName(pattern: string): string

protected setConsumerAssignments(data: ConsumerGroupJoinEvent): void

protected initializeSerializer(options: { postfixId?: string; client?: KafkaConfig; consumer?: ConsumerConfig; run?: Omit<ConsumerRunConfig, "eachBatch" | "eachMessage">; ... 6 more ...; producerOnlyMode?: boolean; })

protected initializeDeserializer(options: { postfixId?: string; client?: KafkaConfig; consumer?: ConsumerConfig; run?: Omit<ConsumerRunConfig, "eachBatch" | "eachMessage">; ... 6 more ...; producerOnlyMode?: boolean; })