kiel.protocol.describe_groups¶

class kiel.protocol.describe_groups.DescribeGroupsRequest(**kwargs)[source]¶

DescribeGroupRequest =>
  groups => [String]

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

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

class kiel.protocol.describe_groups.Assignment(**kwargs)[source]¶

Assignment =>
  version => Int16
  topics => [TopicAssignment]
  user_data => Bytes

class kiel.protocol.describe_groups.MemberDescription(**kwargs)[source]¶

MemberDescription =>
  member_id => String
  client_id => String
  client_host => String
  metadata => Bytes
  assignment => Assignment

class kiel.protocol.describe_groups.GroupDescription(**kwargs)[source]¶

GroupDescription =>
  error_code => Int16
  group_id => String
  state => String
  protocol_type => String
  protocol => String
  members => [MemberDescription]

class kiel.protocol.describe_groups.DescribeGroupsResponse(**kwargs)[source]¶

DescribeGroupResponse =>
  groups => [GroupDescription]