Hmm, that seems like a Kafka bug. Could you try the 0.7.1 release and see if it has the same issue?
Thanks, Jun On Tue, Aug 28, 2012 at 10:09 AM, Mark Grabois <mark.grab...@trendrr.com>wrote: > Hi all, > > While running three consumer processes with common group id across three > machines, I get the following NPE. > > ============================= > > java.lang.NullPointerException (null) > kafka.utils.ZkUtils$.createEphemeralPath(line 56) > kafka.utils.ZkUtils$.createEphemeralPathExpectConflict(line 72) > kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ > ZookeeperConsumerConnector$$registerConsumerInZK(line 208) > kafka.consumer.ZookeeperConsumerConnector.consume(line 175) > kafka.javaapi.consumer.ZookeeperConsumerConnector.createMessageStreams(line > 75) > kafka.javaapi.consumer.ZookeeperConsumerConnector.createMessageStreams(line > 89) > > =============================== > > This causes all three consumer process to terminate simultaneously and > require restart. From the code it looks like zkClient is null, could be > connection to zookeeper was broken? If so, should the consumer just fail > like that? > > The consumer is using kafka-0.7.0 > > Thanks, > Mark >
