Kafka - Create Test Producer and Consumer

You need to make sure both zookeeper and Kafka server are running before executing the commands. Also, please create the Kafka topic before test the producer and consumer.
You can use built-in producer and consumer to test the message flow in Kafka topics.
Please follow the below steps to test it.

  1. Ensure the Kafka topic exists, if not create a new topic using the following command.
    Kafka-topics.bat -create -zookeeper 127.0.0.1:2181 --replication-factor 1 -partitions 1 --topic smstest

  2. To start a producer, use the following command and enter.
    Kafka-console-producer.bat –broker-list 127.0.0.1:9092 –topic smstest

  3. To start a consumer, use the following command and enter.
    Kafka-console-consumer.bat –bootstrap-server 127.0.0.1:9092 –topic smstest

    Now, you can send the message from Producer and check Consumer receives the same message.

  4. You may need to change the server.properties file with following config setting.
    Uncomment the following line
    listeners=PLAINTEXT://:9092
    and change this to
    listeners=PLAINTEXT://127.0.0.1:9092

    The, run the Kafka server using the command.
    .\bin\windows\kafka-server-start.bat .\config\server.properties
    Otherwise, you may get the “Connection to node 0 could not be established” error message.



Related Tutorials