Kind: Type
Source: packages/microservices/external/kafka.interface.ts
Part of: Microservices
Definition
ts{ connect(): Promise<void>; disconnect(): Promise<void>; listTopics(): Promise<string[]>; createTopics(options: { validateOnly?: boolean; waitForLeaders?: boolean; timeout?: number; topics: ITopicConfig[]; }): Promise<boolean>; deleteTopics(options: { topics: string[]; timeout?: number }): Promise<void>; createPartitions(options: { validateOnly?: boolean; timeout?: number; topicPartitions: ITopicPartitionConfig[]; }): Promise<boolean>; fetchTopicMetadata(options?: { topics: string[]; }): Promise<{ topics: Array<ITopicMetadata> }>; fetchOffsets(options: { groupId: string; topics?: string[]; resolveOffsets?: boolean; }): Promise<Array<{ topic: string; partitions: FetchOffsetsPartition[] }>>; fetchTopicOffsets( topic: string, ): Promise<Array<SeekEntry & { high: string; low: string }>>; fetchTopicOffsetsByTimestamp( topic: string, timestamp?: number, ): Promise<Array<SeekEntry>>; describeCluster(): Promise<{ brokers: Array<{ nodeId: number; host: string; port: number }>; controller: number | null; clusterId: string; }>; setOffsets(options: { groupId: string; topic: string; partitions: SeekEntry[]; }): Promise<void>; resetOffsets(options: { groupId: string; topic: string; earliest: boolean; }): Promise<void>; describeConfigs(configs: { resources: ResourceConfigQuery[]; includeSynonyms: boolean; }): Promise<DescribeConfigResponse>; alterConfigs(configs: { validateOnly: boolean; resources: IResourceConfig[]; }): Promise<any>; listGroups(): Promise<{ groups: GroupOverview[] }>; deleteGroups(groupIds: string[]): Promise<DeleteGroupsResult[]>; describeGroups(groupIds: string[]): Promise<GroupDescriptions>; describeAcls(options: AclFilter): Promise<DescribeAclResponse>; deleteAcls(options: { filters: AclFilter[] }): Promise<DeleteAclResponse>; createAcls(options: { acl: AclEntry[] }): Promise<boolean>; deleteTopicRecords(options: { topic: string; partitions: SeekEntry[]; }): Promise<void>; logger(): Logger; on( eventName: AdminEvents['CONNECT'], listener: (event: ConnectEvent) => void, ): RemoveInstrumentationEventListener<typeof eventName>; on( eventName: AdminEvents['DISCONNECT'], listener: (event: DisconnectEvent) => void, ): RemoveInstrumentationEventListener<typeof eventName>; on( eventName: AdminEvents['REQUEST'], listener: (event: RequestEvent) => void, ): RemoveInstrumentationEventListener<typeof eventName>; on( eventName: AdminEvents['REQUEST_QUEUE_SIZE'], listener: (event: RequestQueueSizeEvent) => void, ): RemoveInstrumentationEventListener<typeof eventName>; on( eventName: AdminEvents['REQUEST_TIMEOUT'], listener: (event: RequestTimeoutEvent) => void, ): RemoveInstrumentationEventListener<typeof eventName>; on( eventName: ValueOf<AdminEvents>, listener: (event: InstrumentationEvent<any>) => void, ): RemoveInstrumentationEventListener<typeof eventName>; readonly events: AdminEvents; }
Was this page helpful?