| 1 | import { Logger } from '@nestjs/common/services/logger.service';
|
| 2 | import { BrokersFunction, Consumer, ConsumerGroupJoinEvent, EachMessagePayload, Kafka, Producer } from '../external/kafka.interface';
|
| 3 | import { KafkaParser } from '../helpers';
|
| 4 | import { KafkaOptions, OutgoingEvent, ReadPacket, WritePacket } from '../interfaces';
|
| 5 | import { ClientProxy } from './client-proxy';
|
| 6 | export declare class ClientKafka extends ClientProxy {
|
| 7 | protected readonly options: KafkaOptions['options'];
|
| 8 | protected logger: Logger;
|
| 9 | protected client: Kafka;
|
| 10 | protected consumer: Consumer;
|
| 11 | protected producer: Producer;
|
| 12 | protected parser: KafkaParser;
|
| 13 | protected responsePatterns: string[];
|
| 14 | protected consumerAssignments: {
|
| 15 | [key: string]: number;
|
| 16 | };
|
| 17 | protected brokers: string[] | BrokersFunction;
|
| 18 | protected clientId: string;
|
| 19 | protected groupId: string;
|
| 20 | constructor(options: KafkaOptions['options']);
|
| 21 | subscribeToResponseOf(pattern: any): void;
|
| 22 | close(): Promise<void>;
|
| 23 | connect(): Promise<Producer>;
|
| 24 | bindTopics(): Promise<void>;
|
| 25 | createClient<T = any>(): T;
|
| 26 | createResponseCallback(): (payload: EachMessagePayload) => any;
|
| 27 | getConsumerAssignments(): {
|
| 28 | [key: string]: number;
|
| 29 | };
|
| 30 | protected dispatchEvent(packet: OutgoingEvent): Promise<any>;
|
| 31 | protected getReplyTopicPartition(topic: string): string;
|
| 32 | protected publish(partialPacket: ReadPacket, callback: (packet: WritePacket) => any): () => void;
|
| 33 | protected getResponsePatternName(pattern: string): string;
|
| 34 | protected setConsumerAssignments(data: ConsumerGroupJoinEvent): void;
|
| 35 | protected initializeSerializer(options: KafkaOptions['options']): void;
|
| 36 | protected initializeDeserializer(options: KafkaOptions['options']): void;
|
| 37 | }
|