kiel.protocol.offset_commit¶

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

PartitionV1Request =>
  partition_id => Int32
  offset => Int64
  metadata => String

class kiel.protocol.offset_commit.PartitionV1Request(**kwargs)[source]¶

PartitionV1Request =>
  partition_id => Int32
  offset => Int64
  timestamp => Int64
  metadata => String

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

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

class kiel.protocol.offset_commit.TopicV1Request(**kwargs)[source]¶

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

class kiel.protocol.offset_commit.OffsetCommitV0Request(**kwargs)[source]¶

OffsetCommitV0Request =>
  group => String
  topics => [TopicRequest]

class kiel.protocol.offset_commit.OffsetCommitV1Request(**kwargs)[source]¶

OffsetCommitV1Request =>
  group => String
  generation => Int32
  consumer_id => Int32
  topics => [TopicV1Request]

class kiel.protocol.offset_commit.OffsetCommitV2Request(**kwargs)[source]¶

OffsetCommitV2Request =>
  group => String
  generation => Int32
  consumer_id => Int32
  retention_time => Int64
  topics => [TopicRequest]

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

PartitionResponse =>
  partition_id => Int32
  error_code => Int16

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

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

class kiel.protocol.offset_commit.OffsetCommitResponse(**kwargs)[source]¶

OffsetCommitResponse =>
  topics => [TopicResponse]