class Kafka::Protocol::ProduceRequest

def initialize(required_acks:, timeout:, messages_for_topics:)

Parameters:
  • messages_for_topics (Hash) --
  • timeout (Integer) --
  • required_acks (Integer) -- 
def initialize(required_acks:, timeout:, messages_for_topics:)
  @required_acks = required_acks
  @timeout = timeout
  @messages_for_topics = messages_for_topics
end