consumer terminates, zk npe

[Mark Grabois <ma...@trendrr.com>]

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

Re: consumer terminates, zk npe

[Jun Rao <ju...@gmail.com>]

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 <ma...@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
>