kiel.protocol.sync_group¶

class kiel.protocol.sync_group.TopicAssignment(**kwargs)[source]¶

TopicAssignment =>
  name => String
  partitions => [Int32]

class kiel.protocol.sync_group.MemberAssignment(**kwargs)[source]¶

MemberAssignment =>
  member_id => String
  assignment => Assignment

class kiel.protocol.sync_group.SyncGroupRequest(**kwargs)[source]¶

SyncGroupRequest =>
  group_id => String
  generation_id => Int32
  member_id => String
  assignments => [MemberAssignment]

class kiel.protocol.sync_group.SyncGroupResponse(**kwargs)[source]¶

SyncGroupResponse =>
  error_code => Int16
  assignments => [MemberAssignment]