Apache Kafka Producer Console
Table of Contents
In this article, we will discuss how to publish a message by using the Apache Kafka Producer Console. Kafka having a command-line interface to publish and to consume messages from the topic. Here I will show you how to publish the message and text file from the Kafka Producer Console.
If Apache Kafka software not installed, please install it by seeing the article. Apache Kafka Installation of windows and Linux/Unix is the same. There is the only difference is .bat file for Windows system and .sh files for Linux system
Installation Summary Details
- Kafka Installation home directory in Windows: D:\ApacheKafka-ZooKeeper\kafka
- Kafka Installation home directory in Linux: /home/ApacheKafka-ZooKeeper/kafka
- Kafka Default Port: 9092
- Zookeeper Default Port: 2181
After installing the Apache Kafka, first up all you need to start the Zookeeper and then only start Apache Kafka.
For more Kafka commands, go through the Most important Apache Kafka Commands
Zookeeper Server Start:
Windows: <Kafka-Home>\bin\windows> zookeeper-server-start.bat ..\..\config\zookeeper.properties Linux: <Kafka-Home>\bin> zookeeper-server-start.sh ../../config/zookeeper.properties
Kafka Server Start:
Windows: <Kafka-Home>\bin\windows> kafka-server-start.bat ..\..\config\server.properties Linux: <Kafka-Home>\bin> kafka-server-start.bat.sh ../../config/server.properties
Once the Kafka up and running, then go to <Kafka-Home>\bin\windows for Windows and <Kafka-Home>/bin for Linux system
Kafka Producer Console
Suppose you have a topic i.e MyFirstTopic1. If not having, create the topic by using the following command.
Windows: <Kafka-Home>\bin\windows> kafka-topics.bat --zookeeper localhost:2181 --create --topic MyFirstTopic1 --partitions 1 --replication-factor 1 Linux: <Kafa-Home>\bin$ kafka-topics.sh --zookeeper localhost:2181 --create --topic MyFirstTopic1 --partitions 1 --replication-factor 1
Here we have created topic name is MyFirstTopic1
We can open the producer console to publish the message by executing the following command.
Windows: <Kafka-Home>\bin\windows> kafka-console-producer.bat --broker-list localhost:9092 --topic MyFirstTopic1 Linux: <Kafka-Home>\bin\windows> kafka-console-producer.sh--broker-list localhost:9092 --topic MyFirstTopic1
In the console, you can type the message and hit the enter button then the typed message will be published to the specified topic i.e MyFirstTopic1.
Here how to see the published message. The published message we can see through the consumer console.
Thank you for reading the article, please subscribe and get the latest article into your inbox.
Hello! I am Narayanaswamy founder and admin of narayanatutorial.com. I have been working in IT industry more than 7 years. NarayanaTutorial is my web technologies blog. My specialties are Java / J2EE, Spring, Hibernate, Struts, Webservices, PHP, Oracle, MySQL, SQLServer, Web Hosting and Website Development.
I am a self learner and passionate about training and writing. I am always trying my best to share my knowledge through my blog.