Re: Call to Future.get() hangs for producer

2015-10-09 Thread Jason Kania
rs@kafka.apache.org>; Jason Kania <jason.ka...@ymail.com> Sent: Tuesday, October 6, 2015 5:56 PM Subject: Re: Call to Future.get() hangs for producer Jason, What is the config values for your producer, especially "acks"? And what is the replication scheme you were using on the b

Re: Call to Future.get() hangs for producer

2015-10-06 Thread Guozhang Wang
Jason, What is the config values for your producer, especially "acks"? And what is the replication scheme you were using on the broker side? Guozhang On Tue, Oct 6, 2015 at 6:25 AM, Jason Kania wrote: > Hello, > I am using 8.2.1 and getting a scenario where my send

Call to Future.get() hangs for producer

2015-10-06 Thread Jason Kania
Hello, I am using 8.2.1 and getting a scenario where my send works fine but the subsequent call to Future.get() does not return - it hangs for at least 5 minutes. When I kill the client with the producer I get a Connection reset by peer message in the server.log. I am not sure what to check to