def produce(required_acks, timeout, messages_for_topics)
      ensure_connected
      req = ProduceRequest.new( request_common(:produce),
                                required_acks,
                                timeout,
                                messages_for_topics) 
      send_request(req)
      if required_acks != 0
        read_response(ProduceResponse)
      else
        true
      end
    end
def produce(required_acks, timeout, messages_for_topics)
      ensure_connected
      req = ProduceRequest.new( request_common(:produce),
                                required_acks,
                                timeout,
                                messages_for_topics) 
      send_request(req)
      if required_acks != 0
        read_response(ProduceResponse)
      else
        true
      end
    end
Execute a produce call

 @param [Integer] required_acks
 @param [Integer] timeout
 @param [Array<Protocol::MessagesForTopics>] messages_for_topics Messages to send
 @return [ProduceResponse]