Hi,
I try to read messages from Kafka in Avro format. The topology seems to startup
fine and starts working (it simply outputs a String message, the avro message
isn't parsed). After a few events the following messages appear in the log,
which is repeated a couple of times. After this the processing doesn't work
anymore:
67844 [Thread-17-words] INFO storm.kafka.ZkCoordinator - Task [1/1] Refreshing
partition manager connections
67846 [Thread-17-words] INFO storm.kafka.DynamicBrokersReader - Read partition
info from zookeeper:
GlobalPartitionInformation{partitionMap={0=srvzh-haystack-001.ti8m.ch:6667}}
67846 [Thread-17-words] INFO storm.kafka.KafkaUtils - Task [1/1] assigned
[Partition{host=srvzh-haystack-001.ti8m.ch:6667, partition=0}]
67847 [Thread-17-words] INFO storm.kafka.ZkCoordinator - Task [1/1] Deleted
partition managers: []
67847 [Thread-17-words] INFO storm.kafka.ZkCoordinator - Task [1/1] New
partition managers: []
67847 [Thread-17-words] INFO storm.kafka.ZkCoordinator - Task [1/1] Finished
refreshing
At some point I also get this error:
org.apache.storm.zookeeper.server.PrepRequestProcessor - Got user-level
KeeperException when processing sessionid:0x14df81e06c8000e type:create
cxid:0x3 zxid:0x2b txntype:-1 reqpath:n/a Error
Path:/storm/203e3eeb-cf8e-40d8-bf0a-c235ef4a3b69 Error:KeeperErrorCode = NoNode
for /storm/203e3eeb-cf8e-40d8-bf0a-c235ef4a3b69
org.apache.storm.zookeeper.server.PrepRequestProcessor - Got user-level
KeeperException
I can read the kafka topic with the kafka console consumer perfectly. Has
anyone faced this problem before or would anyone know how to fix it?
Thanks
Alem
[http://www.ti8m.ch/fileadmin/daten/ti8m/Bilder/footer/Footer_Paymit_klein.jpg]<http://www.ti8m.ch/paymit0>
