Ich habe Kafka kürzlich auf einem CDH 5 Setup mit einem einzigen Knoten eingerichtet, um mit ihm auf einem einzelnen Knoten zu spielen, bevor ich zu einem echten Cluster übergehe. Anfangs habe ich den Zoowärterserver mit dem Kafka-Server gestartet und es war alles in Ordnung. Ich konnte sehen, dass Zoowärter auf 2181 lief, während Kafka auf 9092 lief. Ich erstellte dann ein Thema und startete den Verbraucher und der Produzent und der Verbraucher konnte die Nachrichten sehen, die der Produzent sandte.Zookeeper mit KeeperException, aber Kafka kann Themen erstellen und produzieren/konsumieren
Mit Glück auf meinem Gesicht, zog ich auf die Registerkarte mit zookeeper Protokolle und sah dies:
[2015-05-27 16:46:07,016] INFO Got user-level KeeperException when processing sessionid:0x14d97bf0a020002 type:create cxid:0x2 zxid:0x1f txntype:-1 reqpath:n/a Error Path:/consumers/test-consumer-group/ids Error:KeeperErrorCode = NoNode for /consumers/test-consumer-group/ids (org.apache.zookeeper.server.PrepRequestProcessor)
[2015-05-27 16:46:07,021] INFO Got user-level KeeperException when processing sessionid:0x14d97bf0a020002 type:create cxid:0x3 zxid:0x20 txntype:-1 reqpath:n/a Error Path:/consumers/test-consumer-group Error:KeeperErrorCode = NoNode for /consumers/test-consumer-group (org.apache.zookeeper.server.PrepRequestProcessor)
[2015-05-27 16:46:07,306] INFO Got user-level KeeperException when processing sessionid:0x14d97bf0a020002 type:create cxid:0x19 zxid:0x24 txntype:-1 reqpath:n/a Error Path:/consumers/test-consumer-group/owners/test Error:KeeperErrorCode = NoNode for /consumers/test-consumer-group/owners/test (org.apache.zookeeper.server.PrepRequestProcessor)
[2015-05-27 16:46:07,307] INFO Got user-level KeeperException when processing sessionid:0x14d97bf0a020002 type:create cxid:0x1a zxid:0x25 txntype:-1 reqpath:n/a Error Path:/consumers/test-consumer-group/owners Error:KeeperErrorCode = NoNode for /consumers/test-consumer-group/owners (org.apache.zookeeper.server.PrepRequestProcessor)
[2015-05-27 16:47:06,961] INFO Got user-level KeeperException when processing sessionid:0x14d97bf0a020002 type:setData cxid:0x24 zxid:0x29 txntype:-1 reqpath:n/a Error Path:/consumers/test-consumer-group/offsets/test/0 Error:KeeperErrorCode = NoNode for /consumers/test-consumer-group/offsets/test/0 (org.apache.zookeeper.server.PrepRequestProcessor)
[2015-05-27 16:47:06,963] INFO Got user-level KeeperException when processing sessionid:0x14d97bf0a020002 type:create cxid:0x25 zxid:0x2a txntype:-1 reqpath:n/a Error Path:/consumers/test-consumer-group/offsets Error:KeeperErrorCode = NoNode for /consumers/test-consumer-group/offsets (org.apache.zookeeper.server.PrepRequestProcessor)
Es ist wie zookeeper aussieht, ist ein Knoten finden nicht in der Lage. . . Sachen. Aber wenn das der Fall ist, warum funktionieren alle meine Befehle? Ich bin in der Lage, ein Thema zu erstellen, und dann einige Daten für es zu produzieren, während der Verbraucher es abonniert erhält die Daten auch?
Wenn es hilft, ist meine Zookeeper-Version 3.4.6 und meine Kafka-Version ist 0.8.2.1. Und oh, der Pfad/tmp/zookeeper existiert. org.apache.zookeeper.KeeperException $ NoNodeException:
Diese Protokollnachrichten können alt sein. Wenn der Knoten nicht gefunden wird, erstellt er einen neuen Z-Knoten, weshalb Sie diese Knoten sehen können und alle Ihre Befehle funktionieren. – sahu
Dies hat eine ähnliche Lösung zu dieser Frage http://stackoverflow.com/questions/24767337/kafka-startup-failure-version-0-8-0-beta1 – dreffed
Habe bemerkt, dass dies auf neueren Kafka-Servern wurden Cluster hinzugefügt, Es wird wahrscheinlich synchronisiert, was auf ZK ist, nichts zu befürchten, da es nur INFO ist. Die Ausnahme könnte wahrscheinlich auch sein, dass sie bereits vorhanden war, als Kafka versuchte, sie zu erstellen. – kisna