UNPKG

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