Bootstrapping a Kafka env
  05-09-2020 · 1 minute read · 87 words

Startup ZK

./bin/ config/

Standup Kafka

./bin/ config/ &

Creating first topic --zookeeper localhost:2181 --create --topic first --partitions 2 --replication-factor 2

Describe topic

kafka-topics --zookeeper localhost:2181 --describe --topic first

Pub sub Consumer example

Consume the topic first from the Kafka cluster directly. (Subscribe)

kafka-console-consumer --bootstrap-server localhost:9092 --topic first --from-beginning

I believe this is the legacy way of doing this which was to subscribe to the zookeeper broker. However this doesn’t work anymore.

kafka-console-consumer --zookeeper localhost:2181 --topic first

Pub sub Producer example

kafka-console-producer --broker-list localhost:9092 --topic first

comments powered by Disqus