subject:"Re\: Kakfa consumer issue"

RE: Kakfa consumer issue

2018-03-20 Thread Anand, Uttam

Yes checked everything. No errors. Replication factor is 1 only.

-Original Message-
From: Manikumar [mailto:manikumar.re...@gmail.com] 
Sent: Tuesday, March 20, 2018 12:59 PM
To: users@kafka.apache.org
Subject: Re: Kakfa consumer issue

EXTERNAL 
EMAIL check broker logs for any errors. also enable consumer 
debug logs.
check the health of the __consumer_offsets topic. make sure to set
offsets.topic.replication.factor=1 for single node cluster.

On Tue, Mar 20, 2018 at 11:21 PM, Anand, Uttam <uttam.an...@bnsf.com> wrote:

> I don’t want to use --new-consumer as it is the default, so this 
> option is deprecated and will be removed in a future release.
>
> -Original Message-
> From: Anand, Uttam
> Sent: Tuesday, March 20, 2018 12:43 PM
> To: 'users@kafka.apache.org' <users@kafka.apache.org>
> Subject: RE: Kakfa consumer issue
>
> You mean by executing below command ?
>
> /kafka/bin/kafka-console-consumer.sh --new-consumer --bootstrap-server
> kfk03.mp.com:2181 --topic test --from-beginning
>
> -Original Message-
> From: Zakee [mailto:kzak...@netzero.net]
> Sent: Tuesday, March 20, 2018 12:35 PM
> To: users@kafka.apache.org
> Subject: Re: Kakfa consumer issue
>
> EXTERNAL 
> EMAIL Did you try with  --new-consumer  ?
>
> -Zakee
>
> > On Mar 20, 2018, at 10:26 AM, Anand, Uttam <uttam.an...@bnsf.com> wrote:
> >
> > I am facing an issue while consuming message using the 
> > bootstrap-server
> i.e. Kafka server. Any idea why is it not able to consume messages 
> without zookeeper?
> >
> > Kafka Version -: kafka_2.11-1.0.0
> > Zookeeper Version -: kafka_2.11-1.0.0 Server.properties -: Attached 
> > Zookeeper Host and port -: z
> > <http://zkp02.mp.com:2181/>kp02.mp.com:2181
> > <http://zkp02.mp.com:2181/> Kafka Host and port -: kfk03.mp.com:9092 
> > <http://kfk03.mp.com:9092/>
> >
> > Producing some message  -:
> >
> > [kfk03.mp.com <http://kfk03.mp.com/> ~]$ 
> > /bnsf/kafka/bin/kafka-console-producer.sh --broker-list kfk03.mp.com
> > <http://kfk03.mp.com:9092/>:9092 <http://kfk03.mp.com:9092/> --topic 
> > test
> > >hi
> > >hi
> >
> > Consumer not able to consume message if I give –bootstrap-server  -:
> >
> > [kfk03.mp.com <http://kfk03.mp.com/> ~]$ 
> > /bnsf/kafka/bin/kafka-console-consumer.sh --bootstrap-server 
> > kfk03.mp.com <http://kfk03.mp.com:9092/>:9092 
> > <http://kfk03.mp.com:9092/> --topic test --from-beginning
> >
> > Consumer able to consume messages when zookeeper server is given 
> > instead
> of bootstrap-server -:
> >
> > [kfk03.mp.com <http://kfk03.mp.com/> ~]$ 
> > /bnsf/kafka/bin/kafka-console-consumer.sh --zookeeper 
> > zkp02.mp.com:2181
> <http://zkp02.mp.com:2181/> --topic test --from-beginning Using the 
> ConsoleConsumer with old consumer is deprecated and will be removed in 
> a future major release. Consider using the new consumer by passing 
> [bootstrap-server] instead of [zookeeper].
> > {"properties": {"messageType": "test", "sentDateTime":
> > "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29}
> > {"properties": {"messageType": "test", "sentDateTime":
> > "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29}
> > {"properties": {"messageType": "test", "sentDateTime":
> > "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29} 
> > hi
> > {"properties": {"messageType": "test", "sentDateTime":
> > "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29}
> > {"properties": {"messageType": "test", "sentDateTime":
> > "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29}
> > {"properties": {"messageType": "test", "sentDateTime":
> > "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29}
> > {"properties": {"messageType": "test", "sentDateTime":
> > "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29}
> > {"properties": {"messageType": "test", "sentDateTime":
> > "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29} 
> > hi hi uttam hi hi hi hello hi ^CProcessed a total of 17 messages
> >
> > Thanks
> > Uttam
>
> 
> How To Remove Eye Bags & Lip Lines Fast (Watch) Fit Mom Daily 
> http://thirdpartyoffers.netzero.net/TGL3231/5ab14671c27946702f74st04du
> c
>

Re: Kakfa consumer issue

2018-03-20 Thread Manikumar

check broker logs for any errors. also enable consumer debug logs.
check the health of the __consumer_offsets topic. make sure to set
offsets.topic.replication.factor=1 for single node cluster.

On Tue, Mar 20, 2018 at 11:21 PM, Anand, Uttam <uttam.an...@bnsf.com> wrote:

> I don’t want to use --new-consumer as it is the default, so this option is
> deprecated and will be removed in a future release.
>
> -Original Message-
> From: Anand, Uttam
> Sent: Tuesday, March 20, 2018 12:43 PM
> To: 'users@kafka.apache.org' <users@kafka.apache.org>
> Subject: RE: Kakfa consumer issue
>
> You mean by executing below command ?
>
> /kafka/bin/kafka-console-consumer.sh --new-consumer --bootstrap-server
> kfk03.mp.com:2181 --topic test --from-beginning
>
> -Original Message-
> From: Zakee [mailto:kzak...@netzero.net]
> Sent: Tuesday, March 20, 2018 12:35 PM
> To: users@kafka.apache.org
> Subject: Re: Kakfa consumer issue
>
> EXTERNAL
> EMAIL Did you try with  --new-consumer  ?
>
> -Zakee
>
> > On Mar 20, 2018, at 10:26 AM, Anand, Uttam <uttam.an...@bnsf.com> wrote:
> >
> > I am facing an issue while consuming message using the bootstrap-server
> i.e. Kafka server. Any idea why is it not able to consume messages without
> zookeeper?
> >
> > Kafka Version -: kafka_2.11-1.0.0
> > Zookeeper Version -: kafka_2.11-1.0.0
> > Server.properties -: Attached
> > Zookeeper Host and port -: z
> > <http://zkp02.mp.com:2181/>kp02.mp.com:2181
> > <http://zkp02.mp.com:2181/> Kafka Host and port -: kfk03.mp.com:9092
> > <http://kfk03.mp.com:9092/>
> >
> > Producing some message  -:
> >
> > [kfk03.mp.com <http://kfk03.mp.com/> ~]$
> > /bnsf/kafka/bin/kafka-console-producer.sh --broker-list kfk03.mp.com
> > <http://kfk03.mp.com:9092/>:9092 <http://kfk03.mp.com:9092/> --topic
> > test
> > >hi
> > >hi
> >
> > Consumer not able to consume message if I give –bootstrap-server  -:
> >
> > [kfk03.mp.com <http://kfk03.mp.com/> ~]$
> > /bnsf/kafka/bin/kafka-console-consumer.sh --bootstrap-server
> > kfk03.mp.com <http://kfk03.mp.com:9092/>:9092
> > <http://kfk03.mp.com:9092/> --topic test --from-beginning
> >
> > Consumer able to consume messages when zookeeper server is given instead
> of bootstrap-server -:
> >
> > [kfk03.mp.com <http://kfk03.mp.com/> ~]$
> > /bnsf/kafka/bin/kafka-console-consumer.sh --zookeeper zkp02.mp.com:2181
> <http://zkp02.mp.com:2181/> --topic test --from-beginning Using the
> ConsoleConsumer with old consumer is deprecated and will be removed in a
> future major release. Consider using the new consumer by passing
> [bootstrap-server] instead of [zookeeper].
> > {"properties": {"messageType": "test", "sentDateTime":
> > "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29}
> > {"properties": {"messageType": "test", "sentDateTime":
> > "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29}
> > {"properties": {"messageType": "test", "sentDateTime":
> > "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29} hi
> > {"properties": {"messageType": "test", "sentDateTime":
> > "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29}
> > {"properties": {"messageType": "test", "sentDateTime":
> > "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29}
> > {"properties": {"messageType": "test", "sentDateTime":
> > "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29}
> > {"properties": {"messageType": "test", "sentDateTime":
> > "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29}
> > {"properties": {"messageType": "test", "sentDateTime":
> > "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29} hi
> > hi uttam hi hi hi hello hi ^CProcessed a total of 17 messages
> >
> > Thanks
> > Uttam
>
> 
> How To Remove Eye Bags & Lip Lines Fast (Watch) Fit Mom Daily
> http://thirdpartyoffers.netzero.net/TGL3231/5ab14671c27946702f74st04duc
>

RE: Kakfa consumer issue

2018-03-20 Thread Anand, Uttam

I don’t want to use --new-consumer as it is the default, so this option is 
deprecated and will be removed in a future release.

-Original Message-
From: Anand, Uttam 
Sent: Tuesday, March 20, 2018 12:43 PM
To: 'users@kafka.apache.org' <users@kafka.apache.org>
Subject: RE: Kakfa consumer issue

You mean by executing below command ?

/kafka/bin/kafka-console-consumer.sh --new-consumer --bootstrap-server 
kfk03.mp.com:2181 --topic test --from-beginning

-Original Message-
From: Zakee [mailto:kzak...@netzero.net]
Sent: Tuesday, March 20, 2018 12:35 PM
To: users@kafka.apache.org
Subject: Re: Kakfa consumer issue

EXTERNAL 
EMAIL Did you try with  --new-consumer  ?

-Zakee

> On Mar 20, 2018, at 10:26 AM, Anand, Uttam <uttam.an...@bnsf.com> wrote:
> 
> I am facing an issue while consuming message using the bootstrap-server i.e. 
> Kafka server. Any idea why is it not able to consume messages without 
> zookeeper?
>  
> Kafka Version -: kafka_2.11-1.0.0
> Zookeeper Version -: kafka_2.11-1.0.0
> Server.properties -: Attached
> Zookeeper Host and port -: z
> <http://zkp02.mp.com:2181/>kp02.mp.com:2181
> <http://zkp02.mp.com:2181/> Kafka Host and port -: kfk03.mp.com:9092 
> <http://kfk03.mp.com:9092/>
>  
> Producing some message  -:
>  
> [kfk03.mp.com <http://kfk03.mp.com/> ~]$ 
> /bnsf/kafka/bin/kafka-console-producer.sh --broker-list kfk03.mp.com
> <http://kfk03.mp.com:9092/>:9092 <http://kfk03.mp.com:9092/> --topic 
> test
> >hi
> >hi
>  
> Consumer not able to consume message if I give –bootstrap-server  -:
>  
> [kfk03.mp.com <http://kfk03.mp.com/> ~]$ 
> /bnsf/kafka/bin/kafka-console-consumer.sh --bootstrap-server 
> kfk03.mp.com <http://kfk03.mp.com:9092/>:9092 
> <http://kfk03.mp.com:9092/> --topic test --from-beginning
>  
> Consumer able to consume messages when zookeeper server is given instead of 
> bootstrap-server -:
>  
> [kfk03.mp.com <http://kfk03.mp.com/> ~]$ 
> /bnsf/kafka/bin/kafka-console-consumer.sh --zookeeper zkp02.mp.com:2181 
> <http://zkp02.mp.com:2181/> --topic test --from-beginning Using the 
> ConsoleConsumer with old consumer is deprecated and will be removed in a 
> future major release. Consider using the new consumer by passing 
> [bootstrap-server] instead of [zookeeper].
> {"properties": {"messageType": "test", "sentDateTime": 
> "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29}
> {"properties": {"messageType": "test", "sentDateTime": 
> "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29}
> {"properties": {"messageType": "test", "sentDateTime": 
> "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29} hi
> {"properties": {"messageType": "test", "sentDateTime": 
> "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29}
> {"properties": {"messageType": "test", "sentDateTime": 
> "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29}
> {"properties": {"messageType": "test", "sentDateTime": 
> "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29}
> {"properties": {"messageType": "test", "sentDateTime": 
> "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29}
> {"properties": {"messageType": "test", "sentDateTime": 
> "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29} hi 
> hi uttam hi hi hi hello hi ^CProcessed a total of 17 messages
>  
> Thanks
> Uttam


How To Remove Eye Bags & Lip Lines Fast (Watch) Fit Mom Daily 
http://thirdpartyoffers.netzero.net/TGL3231/5ab14671c27946702f74st04duc

RE: Kakfa consumer issue

2018-03-20 Thread Anand, Uttam

You mean by executing below command ?

/kafka/bin/kafka-console-consumer.sh --new-consumer --bootstrap-server 
kfk03.mp.com:2181 --topic test --from-beginning

-Original Message-
From: Zakee [mailto:kzak...@netzero.net] 
Sent: Tuesday, March 20, 2018 12:35 PM
To: users@kafka.apache.org
Subject: Re: Kakfa consumer issue

EXTERNAL 
EMAIL Did you try with  --new-consumer  ?

-Zakee

> On Mar 20, 2018, at 10:26 AM, Anand, Uttam <uttam.an...@bnsf.com> wrote:
> 
> I am facing an issue while consuming message using the bootstrap-server i.e. 
> Kafka server. Any idea why is it not able to consume messages without 
> zookeeper?
>  
> Kafka Version -: kafka_2.11-1.0.0
> Zookeeper Version -: kafka_2.11-1.0.0
> Server.properties -: Attached
> Zookeeper Host and port -: z 
> <http://zkp02.mp.com:2181/>kp02.mp.com:2181 
> <http://zkp02.mp.com:2181/> Kafka Host and port -: kfk03.mp.com:9092 
> <http://kfk03.mp.com:9092/>
>  
> Producing some message  -:
>  
> [kfk03.mp.com <http://kfk03.mp.com/> ~]$ 
> /bnsf/kafka/bin/kafka-console-producer.sh --broker-list kfk03.mp.com 
> <http://kfk03.mp.com:9092/>:9092 <http://kfk03.mp.com:9092/> --topic 
> test
> >hi
> >hi
>  
> Consumer not able to consume message if I give –bootstrap-server  -:
>  
> [kfk03.mp.com <http://kfk03.mp.com/> ~]$ 
> /bnsf/kafka/bin/kafka-console-consumer.sh --bootstrap-server 
> kfk03.mp.com <http://kfk03.mp.com:9092/>:9092 
> <http://kfk03.mp.com:9092/> --topic test --from-beginning
>  
> Consumer able to consume messages when zookeeper server is given instead of 
> bootstrap-server -:
>  
> [kfk03.mp.com <http://kfk03.mp.com/> ~]$ 
> /bnsf/kafka/bin/kafka-console-consumer.sh --zookeeper zkp02.mp.com:2181 
> <http://zkp02.mp.com:2181/> --topic test --from-beginning Using the 
> ConsoleConsumer with old consumer is deprecated and will be removed in a 
> future major release. Consider using the new consumer by passing 
> [bootstrap-server] instead of [zookeeper].
> {"properties": {"messageType": "test", "sentDateTime": 
> "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29}
> {"properties": {"messageType": "test", "sentDateTime": 
> "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29}
> {"properties": {"messageType": "test", "sentDateTime": 
> "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29} hi
> {"properties": {"messageType": "test", "sentDateTime": 
> "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29}
> {"properties": {"messageType": "test", "sentDateTime": 
> "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29}
> {"properties": {"messageType": "test", "sentDateTime": 
> "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29}
> {"properties": {"messageType": "test", "sentDateTime": 
> "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29}
> {"properties": {"messageType": "test", "sentDateTime": 
> "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29} hi 
> hi uttam hi hi hi hello hi ^CProcessed a total of 17 messages
>  
> Thanks
> Uttam


How To Remove Eye Bags & Lip Lines Fast (Watch) Fit Mom Daily 
http://thirdpartyoffers.netzero.net/TGL3231/5ab14671c27946702f74st04duc

Re: Kakfa consumer issue

2018-03-20 Thread Zakee

Did you try with  --new-consumer  ?

-Zakee

> On Mar 20, 2018, at 10:26 AM, Anand, Uttam  wrote:
> 
> I am facing an issue while consuming message using the bootstrap-server i.e. 
> Kafka server. Any idea why is it not able to consume messages without 
> zookeeper?
>  
> Kafka Version -: kafka_2.11-1.0.0
> Zookeeper Version -: kafka_2.11-1.0.0
> Server.properties -: Attached
> Zookeeper Host and port -: z kp02.mp.com:2181 
> 
> Kafka Host and port -: kfk03.mp.com:9092 
>  
> Producing some message  -:
>  
> [kfk03.mp.com  ~]$ 
> /bnsf/kafka/bin/kafka-console-producer.sh --broker-list kfk03.mp.com 
> :9092  --topic test
> >hi
> >hi
>  
> Consumer not able to consume message if I give –bootstrap-server  -:
>  
> [kfk03.mp.com  ~]$
> /bnsf/kafka/bin/kafka-console-consumer.sh --bootstrap-server kfk03.mp.com 
> :9092  --topic test 
> --from-beginning
>  
> Consumer able to consume messages when zookeeper server is given instead of 
> bootstrap-server -:
>  
> [kfk03.mp.com  ~]$ 
> /bnsf/kafka/bin/kafka-console-consumer.sh --zookeeper zkp02.mp.com:2181 
>  --topic test --from-beginning
> Using the ConsoleConsumer with old consumer is deprecated and will be removed 
> in a future major release. Consider using the new consumer by passing 
> [bootstrap-server] instead of [zookeeper].
> {"properties": {"messageType": "test", "sentDateTime": 
> "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29}
> {"properties": {"messageType": "test", "sentDateTime": 
> "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29}
> {"properties": {"messageType": "test", "sentDateTime": 
> "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29}
> hi
> {"properties": {"messageType": "test", "sentDateTime": 
> "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29}
> {"properties": {"messageType": "test", "sentDateTime": 
> "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29}
> {"properties": {"messageType": "test", "sentDateTime": 
> "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29}
> {"properties": {"messageType": "test", "sentDateTime": 
> "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29}
> {"properties": {"messageType": "test", "sentDateTime": 
> "2018-02-25T21:46:00.000+"}, "name": "Uttam Anand", "age": 29}
> hi
> hi
> uttam
> hi
> hi
> hi
> hello
> hi
> ^CProcessed a total of 17 messages
>  
> Thanks
> Uttam 


How To Remove Eye Bags & Lip Lines Fast (Watch)
Fit Mom Daily
http://thirdpartyoffers.netzero.net/TGL3231/5ab14671c27946702f74st04duc

RE: Kakfa consumer issue

Re: Kakfa consumer issue

RE: Kakfa consumer issue

RE: Kakfa consumer issue

Re: Kakfa consumer issue

5 matches

Site Navigation

Mail list logo

Footer information