Assigner

Kind: Type

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

Part of: Microservices

Definition

ts
{ name: string; version: number; assign(group: { members: GroupMember[]; topics: string[]; }): Promise<GroupMemberAssignment[]>; protocol(subscription: { topics: string[] }): GroupState; }