Cluster

Kind: Type

Source: packages/microservices/external/kafka.interface.ts

Part of: Microservices

Definition

ts
{ getNodeIds(): number[]; metadata(): Promise<BrokerMetadata>; removeBroker(options: { host: string; port: number }): void; addMultipleTargetTopics(topics: string[]): Promise<void>; isConnected(): boolean; connect(): Promise<void>; disconnect(): Promise<void>; refreshMetadata(): Promise<void>; refreshMetadataIfNecessary(): Promise<void>; addTargetTopic(topic: string): Promise<void>; findBroker(node: { nodeId: string }): Promise<Broker>; findControllerBroker(): Promise<Broker>; findTopicPartitionMetadata(topic: string): PartitionMetadata[]; findLeaderForPartitions( topic: string, partitions: number[], ): { [leader: string]: number[] }; findGroupCoordinator(group: { groupId: string }): Promise<Broker>; findGroupCoordinatorMetadata(group: { groupId: string; }): Promise<CoordinatorMetadata>; defaultOffset(config: { fromBeginning: boolean }): number; fetchTopicsOffset( topics: Array< { topic: string; partitions: Array<{ partition: number }>; } & XOR<{ fromBeginning: boolean }, { fromTimestamp: number }> >, ): Promise<TopicOffsets[]>; }