Re: java.nio.channels.ClosedChannelException in console-consumer.sh

2016-09-16 Thread Ali Akhtar
Some googling indicates that there are issues on AWS / EC2 when using the private IP, and its recommended to use the public ip as the advertised hostname instead. I have zookeeper and Kafka both running on EC2, and both are in the same availability zone, so both should be able to talk to each othe

Re: java.nio.channels.ClosedChannelException

2015-02-24 Thread Su She
I usually got that exception if a) there is a firewall issue b) you are trying to consume messages from another node and have not set your advertised host name to the public ip address in the kafka server settings. On Tue, Feb 24, 2015 at 12:07 PM, alexey yakubovich < alexe...@yahoo.com.invali

Re: java.nio.channels.ClosedChannelException...Firewall Issue?

2015-01-19 Thread Su She
Hi Jaikiran, Thanks for the reply! 1) I started Kafka server on instance A by simply downloading Kafka_2.10-0.8.2-beta.tgz from the kafka website, and using the scripts mentioned here: http://kafka.apache.org/documentation.html#introduction. This is the same way I downloaded Kafka on B, except I

Re: java.nio.channels.ClosedChannelException...Firewall Issue?

2015-01-19 Thread Jaikiran Pai
Hi Su, How exactly did you start the Kafka server on instance "A"? Are you sure the services on it are bound to non localhost IP? What does the following command result from instance B: telnet public.ip.of.A 9092 -Jaikiran On Tuesday 20 January 2015 07:16 AM, Su She wrote: Hello Everyone,