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 > > <center><p style="color:red; font-size:24px;"><b>EXTERNAL > EMAIL</b></p></center> 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+0000"}, "name": "Uttam Anand", "age": 29} > > {"properties": {"messageType": "test", "sentDateTime": > > "2018-02-25T21:46:00.000+0000"}, "name": "Uttam Anand", "age": 29} > > {"properties": {"messageType": "test", "sentDateTime": > > "2018-02-25T21:46:00.000+0000"}, "name": "Uttam Anand", "age": 29} hi > > {"properties": {"messageType": "test", "sentDateTime": > > "2018-02-25T21:46:00.000+0000"}, "name": "Uttam Anand", "age": 29} > > {"properties": {"messageType": "test", "sentDateTime": > > "2018-02-25T21:46:00.000+0000"}, "name": "Uttam Anand", "age": 29} > > {"properties": {"messageType": "test", "sentDateTime": > > "2018-02-25T21:46:00.000+0000"}, "name": "Uttam Anand", "age": 29} > > {"properties": {"messageType": "test", "sentDateTime": > > "2018-02-25T21:46:00.000+0000"}, "name": "Uttam Anand", "age": 29} > > {"properties": {"messageType": "test", "sentDateTime": > > "2018-02-25T21:46:00.000+0000"}, "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 >
