Re: Testing broker failover

2016-08-08 Thread Alper Akture
producer/ > KafkaProducer.html#send(org.apache.kafka.clients.producer. > ProducerRecord,%20org.apache.kafka.clients.producer.Callback) > > Let us know if you have follow-up questions. > > Alex > > On Mon, Aug 8, 2016 at 11:24 AM, Alper Akture > wrote: > > > Thanks

Re: Testing broker failover

2016-08-08 Thread Alper Akture
record(s) expired due to timeout while requesting metadata from brokers for BACCARAT_ROUND_END-0 On Mon, Aug 8, 2016 at 11:34 AM, Alper Akture wrote: > I also notice that if I use the send method that takes a callback: public > Future send(ProducerRecord record, Callback > callback) { >

Re: Testing broker failover

2016-08-08 Thread Alper Akture
I also notice that if I use the send method that takes a callback: public Future send(ProducerRecord record, Callback callback) { call that in the onCompletionalso all On Mon, Aug 8, 2016 at 11:24 AM, Alper Akture wrote: > Thanks Alex... using producer props: > > {timeout.ms=500, max

Re: Testing broker failover

2016-08-08 Thread Alper Akture
, > > Alex > > On Fri, Aug 5, 2016 at 7:45 PM, Alper Akture > wrote: > > > I'm using 0.10.0.0 and testing some failover scenarios. For dev, i have > > single kafka node and a zookeeper instance. While sending events to a > > topic, I shutdown the broker to see

Testing broker failover

2016-08-05 Thread Alper Akture
I'm using 0.10.0.0 and testing some failover scenarios. For dev, i have single kafka node and a zookeeper instance. While sending events to a topic, I shutdown the broker to see if my failover handling works. However, I don't see any indication that the send failed, but I do see the connection refu