The invalid argument exception on a socket connection looks weird. If you
enable debug on kafka.controller.ControllerChannelManager, it will tell you
which broker the newly elected controller is trying to talk to. Then you
will have to make sure that every broker can connect to every other broker.
What's the host/port registered under /brokers/ids/[brokerId] in ZK?
Thanks,
Jun
On Wed, Aug 7, 2013 at 1:40 AM, 小宇 wrote:
> Hi,I'm new to kafka, and i follow the quickstart guide, when i come to the
> Step 2,i run bin/kafka-server-start.sh config/server.properties , but got
> exception:
> [
Hi,I'm new to kafka, and i follow the quickstart guide, when i come to the
Step 2,i run bin/kafka-server-start.sh config/server.properties , but got
exception:
[2013-08-06 09:55:14,603] INFO 0 successfully elected as leader
(kafka.server.ZookeeperLeaderElector)
[2013-08-06 09:55:14,657] ERROR Erro
