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 <[email protected]>
To: "[email protected]" <[email protected]>; Jason Kania
<[email protected]>
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 <[email protected]> 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
