Method: Kafka::Protocol::ProduceResponse#each_partition

Defined in:
lib/kafka/protocol/produce_response.rb

#each_partition ⇒ Object

[View source]

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