Hi Ewen; Thanks ..Yes broker configuration has been set as you mentioned. But when i try following command, i see this exception..Do you know the reason?
* #kafka-console-consumer.sh --new-consumer --bootstrap-server kafka.xx.com:9092 <http://kafka.xx.com:9092> --topic TEST_NPB4?* [2016-04-06 09:45:26,855] WARN Error while fetching metadata with correlation id 1 : {TEST_NPB4?=INVALID_TOPIC_EXCEPTION} (org.apache.kafka.clients.NetworkClient) [2016-04-06 09:45:27,080] WARN Error while fetching metadata with correlation id 3 : {TEST_NPB4?=INVALID_TOPIC_EXCEPTION} (org.apache.kafka.clients.NetworkClient) [2016-04-06 09:45:27,203] WARN Error while fetching metadata with correlation id 5 : {TEST_NPB4?=INVALID_TOPIC_EXCEPTION} (org.apache.kafka.clients.NetworkClient) [2016-04-06 09:45:27,326] WARN Error while fetching metadata with correlation id 7 : {TEST_NPB4?=INVALID_TOPIC_EXCEPTION} (org.apache.kafka.clients.NetworkClient) [2016-04-06 09:45:27,449] WARN Error while fetching metadata with correlation id 9 : {TEST_NPB4?=INVALID_TOPIC_EXCEPTION} (org.apache.kafka.clients.NetworkClient) [2016-04-06 09:45:27,573] WARN Error while fetching metadata with correlation id 11 : {TEST_NPB4?=INVALID_TOPIC_EXCEPTION} (org.apache.kafka.clients.NetworkClient) [2016-04-06 09:45:27,699] WARN Error while fetching metadata with correlation id 13 : {TEST_NPB4?=INVALID_TOPIC_EXCEPTION} (org.apache.kafka.clients.NetworkClient) [2016-04-06 09:45:27,825] WARN Error while fetching metadata with correlation id 15 : {TEST_NPB4?=INVALID_TOPIC_EXCEPTION} (org.apache.kafka.clients.NetworkClient) [2016-04-06 09:45:27,949] WARN Error while fetching metadata with correlation id 17 : {TEST_NPB4?=INVALID_TOPIC_EXCEPTION} (org.apache.kafka.clients.NetworkClient) [2016-04-06 09:45:28,075] WARN Error while fetching metadata with correlation id 19 : {TEST_NPB4?=INVALID_TOPIC_EXCEPTION} (org.apache.kafka.clients.NetworkClient) [2016-04-06 09:45:28,200] WARN Error while fetching metadata with correlation id 21 : {TEST_NPB4?=INVALID_TOPIC_EXCEPTION} (org.apache.kafka.clients.NetworkClient) [2016-04-06 09:45:28,326] WARN Error while fetching metadata with correlation id 23 : {TEST_NPB4?=INVALID_TOPIC_EXCEPTION} (org.apache.kafka.clients.NetworkClient) [2016-04-06 09:45:28,450] WARN Error while fetching metadata with correlation id 25 : {TEST_NPB4?=INVALID_TOPIC_EXCEPTION} (org.apache.kafka.clients.NetworkClient) [2016-04-06 09:45:28,572] WARN Error while fetching metadata with correlation id 27 : {TEST_NPB4?=INVALID_TOPIC_EXCEPTION} (org.apache.kafka.clients.NetworkClient) [2016-04-06 09:45:28,696] WARN Error while fetching metadata with correlation id 29 : {TEST_NPB4?=INVALID_TOPIC_EXCEPTION} (org.apache.kafka.clients.NetworkClient) [2016-04-06 09:45:28,820] WARN Error while fetching metadata with correlation id 31 : {TEST_NPB4?=INVALID_TOPIC_EXCEPTION} (org.apache.kafka.clients.NetworkClient) [2016-04-06 09:45:28,945] WARN Error while fetching metadata with correlation id 33 : {TEST_NPB4?=INVALID_TOPIC_EXCEPTION} (org.apache.kafka.clients.NetworkClient) [2016-04-06 09:45:29,070] On 6 April 2016 at 07:09, Ewen Cheslack-Postava <e...@confluent.io> wrote: > Ratha, > > In EC2, you probably need to use the advertised.listeners setting (or > advertised.host and advertised.port on older brokers). This is because EC2 > has internal and external addresses for each instance. > > -Ewen > > On Tue, Apr 5, 2016 at 5:13 AM, Ratha v <vijayara...@gmail.com> wrote: > > > Hi all; > > Is there any different connection mechanism for local and remote (ec2 > > instance) server. Im asking because, my consumer is not working with > remote > > server. > > -- > > -Ratha > > http://vvratha.blogspot.com/ > > > > > > -- > Thanks, > Ewen > -- -Ratha http://vvratha.blogspot.com/
