UNPKG

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