Fw: Exception when using simple consumer fetching offsets.

[James Teng]

Hi,

i am working on a monitoring system, when i try to monitor consumer offsets on 
remote kafka cluster, i got an error using SimpleConsumer api.

i found a post on stackoverlflow saying i should set advertised.host.name=xxx 
for all the broker servers. i discovered that all the broker servers already 
have host.name properties set to ip address in the server.properties file. i 
wonder whether there is an approach to work out on the client side.
Below is the exception trace.

java.nio.channels.ClosedChannelException: null
        at kafka.network.BlockingChannel.send(BlockingChannel.scala:110) 
~[kafka_2.11-0.9.0.1.jar:?]
        at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:85) 
[kafka_2.11-0.9.0.1.jar:?]
        at 
kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:83)
 [kafka_2.11-0.9.0.1.jar:?]
        at kafka.consumer.SimpleConsumer.fetchOffsets(SimpleConsumer.scala:169) 
[kafka_2.11-0.9.0.1.jar:?]
....


any comment is appreciated.

james.