Jason, How did you validate that the message has been received at the server side?
Guozhang On Fri, Oct 9, 2015 at 8:27 PM, Jason Kania <jason.ka...@ymail.com> wrote: > HI Guozhang, > Thanks for replying. I have minimal configuration at this point. I am only > trying to get the new producer working with a single kafka node with the > replication factor on my topic set to 1. I am only setting the > bootstrap.servers variable so the acks looks like it would be 1. I have > turned on debugging and traces, but see nothing that would indicate an > error. It looks like the message is received and processed but no response > is received at the client. > > Thanks, > Jason > > From: Guozhang Wang <wangg...@gmail.com> > To: "users@kafka.apache.org" <users@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 broker side? > > Guozhang > > > > On Tue, Oct 6, 2015 at 6:25 AM, Jason Kania <jason.ka...@ymail.com> wrote: > > > 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 see > what > > is happening. None of the other logs are updated when I send. This is on > a > > system with no other producers. > > Any suggestions on debugging this would be appreciated. > > Thanks, > > Jason > > > > > -- > -- Guozhang > > > > -- -- Guozhang
