kiel.protocol.produce¶

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

PartitionRequest =>
  partition_id => Int32
  message_set => MessageSet

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

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

class kiel.protocol.produce.ProduceRequest(**kwargs)[source]¶

ProduceRequest =>
  required_acs => Int16
  timeout => Int32
  topics => [TopicRequest]

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

PartitionResponse =>
  partition_id => Int32
  error_code => Int16
  offset => Int64

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

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

class kiel.protocol.produce.ProduceResponse(**kwargs)[source]¶

ProduceResponse =>
  topics => [TopicResponse]