kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Anand, Uttam" <Uttam.An...@BNSF.com>
Subject RE: Kakfa consumer issue
Date Tue, 20 Mar 2018 18:10:24 GMT
Yes checked everything. No errors. Replication factor is 1 only.

-----Original Message-----
From: Manikumar [mailto:manikumar.reddy@gmail.com] 
Sent: Tuesday, March 20, 2018 12:59 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>
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.Anand@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:kzakee1@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.Anand@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/5ab14671c27946702f74st04du
> c
>
Mime
View raw message