kiel.protocol.metadata¶

class kiel.protocol.metadata.MetadataRequest(**kwargs)[source]¶

MetadataRequest =>
  topics => [String]

class kiel.protocol.metadata.Broker(**kwargs)[source]¶

Broker =>
  broker_id => Int32
  host => String
  port => Int32

class kiel.protocol.metadata.PartitionMetadata(**kwargs)[source]¶

PartitionMetadata =>
  error_code => Int16
  partition_id => Int32
  leader => Int32
  replicas => [Int32]
  isrs => [Int32]

class kiel.protocol.metadata.TopicMetadata(**kwargs)[source]¶

TopicMetadata =>
  error_code => Int16
  name => String
  partitions => [PartitionMetadata]

class kiel.protocol.metadata.MetadataResponse(**kwargs)[source]¶

MetadataResponse =>
  brokers => [Broker]
  topics => [TopicMetadata]