kiel.protocol.offset_fetch
¶kiel.protocol.offset_fetch.
TopicRequest
(**kwargs)[source]¶TopicRequest =>
name => String
partitions => [In32]
kiel.protocol.offset_fetch.
OffsetFetchRequest
(**kwargs)[source]¶OffsetFetchRequest =>
group_name => String
topics => [TopicRequest]
kiel.protocol.offset_fetch.
PartitionResponse
(**kwargs)[source]¶PartitionResponse =>
partition_id => Int32
offset => Int64
metadata => String
error_code => Int16