kiel.protocol.produce
¶kiel.protocol.produce.
PartitionRequest
(**kwargs)[source]¶PartitionRequest =>
partition_id => Int32
message_set => MessageSet
kiel.protocol.produce.
TopicRequest
(**kwargs)[source]¶TopicRequest =>
name => String
partitions => [PartitionRequest]
kiel.protocol.produce.
ProduceRequest
(**kwargs)[source]¶ProduceRequest =>
required_acs => Int16
timeout => Int32
topics => [TopicRequest]
kiel.protocol.produce.
PartitionResponse
(**kwargs)[source]¶PartitionResponse =>
partition_id => Int32
error_code => Int16
offset => Int64