- last edited on
I am trying to run Kafka 1.0.1 on a single-node cdh5.13.0.
I was able to create a topic by:
Kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 -partitions 1 --topic kafka_demo5
But i have issues when running producer and consumer:
Kafka-console-producer --broker-list quickstart.cloudera:9092 --topic kafka_demo5
Kafka-console-consumer --bootstrap-server quickstart.cloudera:9092 --topic kafka_demo5 --from-beginning
When I run producer-consumer commands I get a similar but very long output [pic]. Output also doesn't list any error if occurred.