Strange behaviour of KafkaSpout [Zookeeper Error???]

[Palak Shah <sp...@gmail.com>]

Hi everyone,

Has anyone succesfully been able to read from a Kafka queue using
kafkaSpout available in storm version *apache-storm-0.9.2-incubating?  *I
am trying to use a kafkaSpout in my topology I am getting some weird
behaviour from the spout. I am using *apache-storm-0.9.2-incubating and
kafka_2.9.2-0.8.1.1*.

When I run my topology in Local Cluster mode, it prints something like this
-

*Value of Tuple = source: kafkaSpout:6, stream: default, id:
{2740689624846702269=5833267146774393576}, [[B@1500df0b] 7005
[Thread-9-kafkaBolt] INFO storm.kafka.KafkaTopology - source: kafkaSpout:6,
stream: default, id: {2740689624846702269=5833267146774393576},
[[B@1500df0b]*

instead of the actual value of tuple, which looks like this -

*[ValueFloat:-24.0936545121942][TagUID:fe58715b-881e-3d40-9117-d7168b4a307f][TagTimeStamp:1406700227000]*

When I submit the topology to Storm cluster, it is submitted correctly. But
when I check the UI, it shows that kafkaSpout is not receiving or emitting
any tuples.

After sometime, UI displays the following error for kafkaSpout -

*java.lang.RuntimeException: java.lang.RuntimeException:
org.apache.zookeeper.KeeperException$ConnectionLossException:
KeeperErrorCode = ConnectionLoss for /brokers/topics/page_visits/partitions
at st*

I checked that my topic is populated with the correct values and that I am
able to connect to the zookeeper (localhost:2181) and Brokers
(localhost:9092 and localhost:9093).

I'd really appreciate it if anyone can come up with a solution for this

Thanks,
Palak.