Simple Consumer Exceptions

[Achanta Vamsi Subhash]

Hi,

We are getting the below exceptions while trying to get the last offset of
a topic. The code being used is taken from here:
https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example

We are finding the lead broker and getting the offsets and noticing the
failures due to the below exception. What could be the problem?

Kafka Version: 0.8.2.1

java.nio.channels.ClosedChannelException: null
        at kafka.network.BlockingChannel.send(BlockingChannel.scala:100)
~[varadhi.jar:2.0]
        at
kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:78)
~[varadhi.jar:2.0]
        at
kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:68)
~[varadhi.jar:2.0]
        at
kafka.consumer.SimpleConsumer.getOffsetsBefore(SimpleConsumer.scala:127)
~[varadhi.jar:2.0]
        at
kafka.javaapi.consumer.SimpleConsumer.getOffsetsBefore(SimpleConsumer.scala:79)
~[varadhi.jar:2.0]

-- 
Regards
Vamsi Subhash