kiel.protocol.offset_fetch¶

class kiel.protocol.offset_fetch.TopicRequest(**kwargs)[source]¶

TopicRequest =>
  name => String
  partitions => [In32]

class kiel.protocol.offset_fetch.OffsetFetchRequest(**kwargs)[source]¶

OffsetFetchRequest =>
  group_name => String
  topics => [TopicRequest]

class kiel.protocol.offset_fetch.PartitionResponse(**kwargs)[source]¶

PartitionResponse =>
  partition_id => Int32
  offset => Int64
  metadata => String
  error_code => Int16

class kiel.protocol.offset_fetch.TopicResponse(**kwargs)[source]¶

TopicResponse =>
  name => String
  partitions => [PartitionResponse]

class kiel.protocol.offset_fetch.OffsetFetchResponse(**kwargs)[source]¶

OffsetFetchResponse =>
  topics => [TopicResponse]