Support Questions
Find answers, ask questions, and share your expertise
Announcements
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.

kafka consumer does not receinve messages

kafka consumer does not receinve messages

Explorer

Hi all,

we are building a small kafka env, 4 nodes: 01.node, 02.node, 03.node, 04.node

 

the topic creation:

/usr/bin/kafka-topics --zookeeper 01.node:2181 --create --replication-factor 1 --partitions 1 --topic mytest

 

the producer and brokers:

/usr/bin/kafka-console-producer --broker-list 03.node,04.node:9092 --topic mytest

 

the consumer:

/usr/bin/kafka-console-consumer --bootstrap-server 01.node:2181 --topic mytest --from-beginning

 

the weird stuff is that consumer statement does not accept the --zookeeper option, so we put --bootstrap-server instead of it

 

everything seems good: producer waits for input, consumer seems waiting for messages...

 

but when you enter input (a string CRLF ended) on the producer, nothing happens on the consumer side...

 

no mesg arrive

 

any ideas? what we are going wrong?

 

thanks, bye marco

1 REPLY 1
Highlighted

Re: kafka consumer does not receinve messages

Explorer

brokers seems to receive messages (see attached picture) and connections from brokers (netstat -nascreenshot.9.jpg) seems ok but consumer does not yet receive...

Don't have an account?
Coming from Hortonworks? Activate your account here