You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Jason Kania <ja...@ymail.com> on 2015/10/06 15:25:31 UTC
Call to Future.get() hangs for producer
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
Re: Call to Future.get() hangs for producer
Posted by Guozhang Wang <wa...@gmail.com>.
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 <ja...@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 <wa...@gmail.com>
> To: "users@kafka.apache.org" <us...@kafka.apache.org>; Jason Kania <
> jason.kania@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 <ja...@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
Re: Call to Future.get() hangs for producer
Posted by Jason Kania <ja...@ymail.com>.
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 <wa...@gmail.com>
To: "users@kafka.apache.org" <us...@kafka.apache.org>; Jason Kania <ja...@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 <ja...@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
Re: Call to Future.get() hangs for producer
Posted by Guozhang Wang <wa...@gmail.com>.
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 <ja...@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