kiel.protocol.offset_commit
¶kiel.protocol.offset_commit.
PartitionRequest
(**kwargs)[source]¶PartitionV1Request =>
partition_id => Int32
offset => Int64
metadata => String
kiel.protocol.offset_commit.
PartitionV1Request
(**kwargs)[source]¶PartitionV1Request =>
partition_id => Int32
offset => Int64
timestamp => Int64
metadata => String
kiel.protocol.offset_commit.
TopicRequest
(**kwargs)[source]¶TopicRequest =>
name => String
partitions => [PartitionRequest]
kiel.protocol.offset_commit.
TopicV1Request
(**kwargs)[source]¶TopicRequest =>
name => String
partitions => [PartitionV1Request]
kiel.protocol.offset_commit.
OffsetCommitV0Request
(**kwargs)[source]¶OffsetCommitV0Request =>
group => String
topics => [TopicRequest]
kiel.protocol.offset_commit.
OffsetCommitV1Request
(**kwargs)[source]¶OffsetCommitV1Request =>
group => String
generation => Int32
consumer_id => Int32
topics => [TopicV1Request]
kiel.protocol.offset_commit.
OffsetCommitV2Request
(**kwargs)[source]¶OffsetCommitV2Request =>
group => String
generation => Int32
consumer_id => Int32
retention_time => Int64
topics => [TopicRequest]
kiel.protocol.offset_commit.
PartitionResponse
(**kwargs)[source]¶PartitionResponse =>
partition_id => Int32
error_code => Int16