Method: Kafka::Protocol::ProduceResponse#each_partition
- Defined in:
- lib/kafka/protocol/produce_response.rb
#each_partition ⇒ Object
33 34 35 36 37 38 39 |
# File 'lib/kafka/protocol/produce_response.rb', line 33 def each_partition @topics.each do |topic_info| topic_info.partitions.each do |partition_info| yield topic_info, partition_info end end end |