KAFKA – Using Command-Line Producer and Consumer

STEP 2: START THE KAFKA ENVIRONMENT

NOTE: Your local environment must have Java 8+ installed.

Apache Kafka can be started using ZooKeeper or KRaft. To get started with either configuration follow one the sections below but not both.

Kafka with ZooKeeper

zookeeper-server-start ../../config/zookeeper.properties

Open another terminal session and run:

kafka-server-start ../../config/server.properties

STEP 3: CREATE A TOPIC TO STORE YOUR EVENTS

kafka-topics --create --topic quickstart-events --bootstrap-server localhost:9092

STEP 4: WRITE SOME EVENTS INTO THE TOPIC

kafka-console-producer --topic quickstart-events --bootstrap-server localhost:9092

STEP 5: READ THE EVENTS

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

STEP 6: WRITE FILE EVENTS INTO THE TOPIC

kafka-console-producer --topic quickstart-events --broker-list < ../data/sample1.csv

STEP 7: READ THE EVENTS

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