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
