jeygeethan / docker-kafka-cluster Goto Github PK

#docker run \
>   --name=kafka2 \
>   -p 9092:9092 \
>   -e KAFKA_HOST=server2.server.de \
>   -e KAFKA_PORT=9092 \
>   -e ZOOKEEPER_CONNECT=server1.server.de:2181,server2.server.de:2181 \
>   -e BROKER_ID=1 \
>   -d jeygeethan/kafka-cluster
9f7137bbf5269c1810308d0f28bfdf33a83673e250b2947877daf5f4e05d486c

# docker logs -f kafka2
advertised host: server2.server.de
advertised port: 9092
zookeeper connect: server1.server.de.de:2181,server2.server.de.de:2181
[2017-04-05 21:53:55,272] INFO KafkaConfig values:
	advertised.host.name = server2.server.de
	...
	broker.id = 0
	...
 (kafka.server.KafkaConfig)
[2017-04-05 21:53:55,309] INFO starting (kafka.server.KafkaServer)
[2017-04-05 21:53:55,311] INFO Connecting to zookeeper on server1.server.de:2181,server2.server.de:2181 (kafka.server.KafkaServer)
[2017-04-05 21:53:55,318] INFO Starting ZkClient event thread. (org.I0Itec.zkclient.ZkEventThread)
[2017-04-05 21:53:55,321] INFO Client environment:zookeeper.version=3.4.6-1569965, built on 02/20/2014 09:09 GMT (org.apache.zookeeper.ZooKeeper)
[2017-04-05 21:53:55,321] INFO Client environment:host.name=9f7137bbf526 (org.apache.zookeeper.ZooKeeper)
[2017-04-05 21:53:55,321] INFO Client environment:java.version=1.8.0_102 (org.apache.zookeeper.ZooKeeper)
[2017-04-05 21:53:55,321] INFO Client environment:java.vendor=Oracle Corporation (org.apache.zookeeper.ZooKeeper)
[2017-04-05 21:53:55,321] INFO Client environment:java.home=/usr/lib/jvm/java-8-openjdk-amd64/jre (org.apache.zookeeper.ZooKeeper)
...
[2017-04-05 21:53:55,686] INFO Creating /brokers/ids/0 (is it secure? false) (kafka.utils.ZKCheckedEphemeral)
[2017-04-05 21:53:55,694] INFO Result of znode creation is: NODEEXISTS (kafka.utils.ZKCheckedEphemeral)
[2017-04-05 21:53:55,695] FATAL [Kafka Server 0], Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
java.lang.RuntimeException: A broker is already registered on the path /brokers/ids/0. This probably indicates that you either have configured a brokerid that is already in use, or else you have shutdown this broker and restarted it faster than the zookeeper timeout so it appears to be re-registering.
	at kafka.utils.ZkUtils.registerBrokerInZk(ZkUtils.scala:295)
	at kafka.utils.ZkUtils.registerBrokerInZk(ZkUtils.scala:281)
	at kafka.server.KafkaHealthcheck.register(KafkaHealthcheck.scala:64)
	at kafka.server.KafkaHealthcheck.startup(KafkaHealthcheck.scala:45)
	at kafka.server.KafkaServer.startup(KafkaServer.scala:231)
	at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:37)
	at kafka.Kafka$.main(Kafka.scala:67)
	at kafka.Kafka.main(Kafka.scala)
[2017-04-05 21:53:55,696] INFO [Kafka Server 0], shutting down (kafka.server.KafkaServer)
[2017-04-05 21:53:55,697] INFO [Socket Server on Broker 0], Shutting down (kafka.network.SocketServer)
[2017-04-05 21:53:55,704] INFO [Socket Server on Broker 0], Shutdown completed (kafka.network.SocketServer)