kiel.protocol.metadata
¶kiel.protocol.metadata.
MetadataRequest
(**kwargs)[source]¶MetadataRequest =>
topics => [String]
kiel.protocol.metadata.
Broker
(**kwargs)[source]¶Broker =>
broker_id => Int32
host => String
port => Int32
kiel.protocol.metadata.
PartitionMetadata
(**kwargs)[source]¶PartitionMetadata =>
error_code => Int16
partition_id => Int32
leader => Int32
replicas => [Int32]
isrs => [Int32]