kiel.protocol.fetch¶

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

PartitionRequest =>
  partition_id => Int32
  offset => Int64
  max_bytes => Int32

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

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

class kiel.protocol.fetch.FetchRequest(**kwargs)[source]¶

FetchRequest =>
  replica_id => Int32
  max_wait_time => Int32
  min_bytes => Int32
  topics => [TopicRequest]

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

PartitionResponse =>
  partition_id => Int32
  error_code => Int16
  highwater_mark_offset => Int64
  message_set => MessageSet

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

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

class kiel.protocol.fetch.FetchResponse(**kwargs)[source]¶

FetchResponse =>
  topics => [TopicResponse]