Working with Kafka from the Command Line

1. Create the topic using the kafka-topics command:

kafka-topics --create --bootstrap-server localhost:9092 --replication-factor 3 --partitions 6 --topic inventory_purchases

1. Start a command line producer:

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

1. Type in a few lines of test data. Since we are working with merely test data, a specific format is not required. It could look like this:

product: apples, quantity: 5
product: lemons, quantity: 7

1. Once the test messages are published, we can exit the producer.

2. Start up a command line consumer:

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

1. We should see the test messages that were published earlier:

product: apples, quantity: 5
product: lemons, quantity: 7