Re: Mysterious timeout

2016-11-04 Thread Becket Qin
! > > short code = fetchResponse.errorCode(a_topic, a_partition); > > System.out.println("Error fetching data from the Broker:" + > > leadBroker + " Reason: " + code); > > ____ > > From: Mike Kaplinskiy

Re: Mysterious timeout

2016-11-04 Thread Jeff Widman
> Sent: Thursday, October 27, 2016 3:11:14 AM > To: users@kafka.apache.org > Subject: Mysterious timeout > > Hey folks, > > We're observing a very peculiar behavior on our Kafka cluster. When one of > the Kafka broker instances goes down, we're seeing the producer bl

Re: Mysterious timeout

2016-10-27 Thread Martin Gainty
_ From: Mike Kaplinskiy Sent: Thursday, October 27, 2016 3:11:14 AM To: users@kafka.apache.org Subject: Mysterious timeout Hey folks, We're observing a very peculiar behavior on our Kafka cluster. When one of the Kafka broker instances goes down, we're seeing the p

Mysterious timeout

2016-10-27 Thread Mike Kaplinskiy
Hey folks, We're observing a very peculiar behavior on our Kafka cluster. When one of the Kafka broker instances goes down, we're seeing the producer block (at .flush) for right about `request.timeout.ms` before returning success (or at least not throwing an exception) and moving on. We're runnin