kiel.protocol.offset¶

class kiel.protocol.offset.PartitionRequest(**kwargs)[source]¶

PartitionRequeset =>
  partition_id => Int32
  time => Int64
  max_offsets => Int32

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

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

class kiel.protocol.offset.OffsetRequest(**kwargs)[source]¶

OffsetRequest =>
  replica_id => Int32
  topics => [TopicRequest]

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

PartitionResponse =>
  partition_id => Int32
  error_code => Int16
  offsets => [Int64]

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

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

class kiel.protocol.offset.OffsetResponse(**kwargs)[source]¶

OffsetResponse =>
  topics => [TopicResponse]