pub fn produce_messages<'a, 'b, I, J>(&mut self,
                                          acks: RequiredAcks,
                                          ack_timeout: Duration,
                                          messages: I)
                                          -> Result<Vec<TopicPartitionOffset>>
        where J: AsRef<ProduceMessage<'a, 'b>>,
              I: IntoIterator<Item = J>
    {
        self.internal_produce_messages(acks as i16,
                                       try!(protocol::to_millis_i32(ack_timeout)),
                                       messages)
    }
// XXX rework signaling an error; note that we need to either return the
// messages which kafka failed to accept or otherwise tell the client about them
XXX rework signaling an error; note that we need to either return the
messages which kafka failed to accept or otherwise tell the client about them
XXX rework signaling an error ; note that we need to either return the messages which kafka failed to accept or otherwise tell the client about them
pub fn produce_messages<'a, 'b, I, J>(&mut self,
                                          acks: RequiredAcks,
                                          ack_timeout: Duration,
                                          messages: I)
                                          -> Result<Vec<TopicPartitionOffset>>
        where J: AsRef<ProduceMessage<'a, 'b>>,
              I: IntoIterator<Item = J>
    {
        self.internal_produce_messages(acks as i16,
                                       try!(protocol::to_millis_i32(ack_timeout)),
                                       messages)
    }
pub fn produce_messages < ' a , ' b , I , J > ( & mut self , acks : RequiredAcks , ack_timeout : Duration , messages : I ) -> Result < Vec < TopicPartitionOffset > > where J : AsRef < ProduceMessage < ' a , ' b > > , I : IntoIterator < Item = J > { self . internal_produce_messages ( acks as i16 , try ! ( protocol to_millis_i32 ( ack_timeout ) ) , messages ) }
XXX rework signaling an error; note that we need to either return the
messages which kafka failed to accept or otherwise tell the client about them
XXX rework signaling an error ; note that we need to either return the messages which kafka failed to accept or otherwise tell the client about them
&mut self
acks
RequiredAcks
ack_timeout
Duration
messages
I