Method: Kafka::Protocol::ProduceResponse#initialize

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

#initialize(topics: [], throttle_time_ms: 0) ⇒ ProduceResponse

Returns a new instance of ProduceResponse.



28
29
30
31
 
# File 'lib/kafka/protocol/produce_response.rb', line 28

def initialize(topics: [], throttle_time_ms: 0)
  @topics = topics
  @throttle_time_ms = throttle_time_ms
end