You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by wangxu <sa...@gmail.com> on 2013/10/11 00:53:12 UTC

Problem when follows the "chapter 1.3 quick start" in kafka documentation

Hi,

Following the _kafka documentation_ 
<http://kafka.apache.org/documentation.html#quickstart>, I succeeded in 
Step 1: Download the code, Step 2: Start the server and Step 3: Create a 
topic in three different terminals.
While I tried Step 4: Send some messages, the problem happened, the 
producer for the topic "test" could be started, however, I got an 
exception in the producer console (the fourth terminal) after I sent 
"This is a message" in the producer console. The exception looks like 
:"kafka.common.FailedToSendMessageException: Failed to send messages 
after 3 tries."
I put the detail information to the attachment "producer_terminal.log".
The attachement "server.log.2013-10-11-05" keeps a piece of information 
about java.net.ConnectException that seems to be the key of the problem. 
But I have no idea how this can happen.

I also tried to have a consumer connecting to the topic ready before 
sending the message in producer terminal, the problem was the same.

My environment:
CentOS 6.4 (x64), kafka-0.8.0-beta1-src, jdk 1.6.0_31

Can anyone help? Thanks in advance.

Best regards,

WangXu(Alvin)

Re: Problem when follows the "chapter 1.3 quick start" in kafka documentation

Posted by Guozhang Wang <wa...@gmail.com>.
Hello,

Could you try to check your zookeeper log to see if the topic has been
successfully created and the broker has been selected by the controller to
be the leader of this topic? The log entry should be something like

Broker %d handling LeaderAndIsr request correlation id ...

BTW from your logs the server only successfully elect as the controller in
06:30 while the producer's exceptions are in 06:13, so could you check in
the kafka-controller log to see if the server elected itself as the
controller before 06:13? The log entry should be something like

Broker %d starting become controller state transition ...

Guozhang


On Thu, Oct 10, 2013 at 3:53 PM, wangxu <sa...@gmail.com> wrote:

>  Hi,
>
> Following the *kafka documentation*<http://kafka.apache.org/documentation.html#quickstart>,
> I succeeded in Step 1: Download the code, Step 2: Start the server and Step
> 3: Create a topic in three different terminals.
> While I tried Step 4: Send some messages, the problem happened, the
> producer for the topic "test" could be started, however, I got an exception
> in the producer console (the fourth terminal) after I sent "This is a
> message" in the producer console. The exception looks like
> :"kafka.common.FailedToSendMessageException: Failed to send messages after
> 3 tries."
> I put the detail information to the attachment "producer_terminal.log".
> The attachement "server.log.2013-10-11-05" keeps a piece of information
> about java.net.ConnectException that seems to be the key of the problem.
> But I have no idea how this can happen.
>
> I also tried to have a consumer connecting to the topic ready before
> sending the message in producer terminal, the problem was the same.
>
> My environment:
> CentOS 6.4 (x64), kafka-0.8.0-beta1-src, jdk 1.6.0_31
>
> Can anyone help? Thanks in advance.
>
> Best regards,
>
> WangXu(Alvin)
>



-- 
-- Guozhang