{"id":577,"date":"2026-09-13T09:36:52","date_gmt":"2026-09-13T09:36:52","guid":{"rendered":"https:\/\/prwatech.in\/blog\/?p=577"},"modified":"2026-09-14T15:54:49","modified_gmt":"2026-09-14T15:54:49","slug":"apache-kafka-use-case-tutorial","status":"publish","type":"post","link":"https:\/\/prwatech.in\/blog\/apache-spark\/apache-spark-kafka\/apache-kafka-use-case-tutorial\/","title":{"rendered":"Apache Spark Kafka Usecase"},"content":{"rendered":"

Apache Kafka Use Case Tutorial<\/h1>\n

Welcome to the world of advanced Tutorials on the use case for apache spark. Are you looking forward to the Use case example of the Kafka Platform? Or looking for some help on the use case for Kafka streams? Then you\u2019ve landed on the Right Path which providing advanced tutorial Based concepts on the Apache Kafka Use Case Examples. In this tutorial, one can easily explore apache Apache Spark real-world Use Cases with step by step explanation.<\/p>\n

If you are the one who wanted to become an expert in Apache spark? Or the one who wanted to explore the technology like a Pro under the certified experts with world-class classroom training environment, then asks your Apache spark training institute experts who offer advanced Apache spark training<\/a>. Follow the below-mentioned Apache spark use case tutorial and enhance your skills to become a professional Spark Developer.<\/p>\n

Apache Kafka Use Case<\/h2>\n

The examples below walk through core Kafka operations using the command line tools that ship with Kafka: creating a topic, sending and receiving messages, replicating a topic across brokers, and deleting a topic.<\/p>\n

Case 1.\u00a0 One producer and one consumer<\/strong><\/h3>\n

Create a topic named Hello Kafka:<\/strong><\/p>\n

bin\/Kafka-topics.sh –>create –>zookeeper localhost:2181 –>replication-factor 1 –>partitions 1 –>topic Hello-Kafka<\/p>\n

\"Apache<\/strong><\/p>\n

bin\/Kafka-console-producer.sh –broker-list localhost:9092 –topic Hello-Kafka<\/strong><\/p>\n

Start a producer and write a message to that topic:<\/p>\n

\"Run<\/strong><\/p>\n

Run the consumer<\/strong><\/p>\n

bin\/Kafka-console-consumer.sh –bootstrap-server localhost:9092 –topic test –from-beginning<\/strong><\/p>\n

Start a consumer to read messages from the same topic, from the beginning:<\/p>\n

\"You<\/strong><\/p>\n

Case 2: Creating a Replicated Topic<\/h3>\n

This case creates a topic with a replication factor of 2, meaning each message is kept on two brokers instead of one. A replication factor of 2 needs at least two brokers running to succeed, which is what Case 3, right after this one, sets up. If you try this on a single broker setup, Kafka will reject it with a replication factor error, so come back to this step once your second broker is running.<\/p>\n

bin\/Kafka-topics.sh –create –zookeeper localhost:2181 –replication-factor 2 –partitions 1 –topic\u00a0Multibrokerapplication<\/strong><\/p>\n

\"topic\u00a0Multibrokerapplication\"<\/strong><\/p>\n

bin\/Kafka-console-producer.sh –broker-list localhost:9092 –topic Multibrokerapplication<\/strong><\/p>\n

\"topic\u00a0Multibrokerapplication<\/strong><\/p>\n

bin\/Kafka-console-consumer.sh –bootstrap-server localhost:9092 –topic institute –from-beginning<\/strong><\/p>\n

\"topic<\/strong><\/p>\n

Case 3: Setting Up a Multi Broker Cluster<\/h3>\n

The classic way to add a second broker on the same machine was to copy server.properties into a new file, such as server-one.properties, and give it its own broker ID, port, and log directory. That approach was built for ZooKeeper based Kafka. In current KRaft based Kafka, there is no ZooKeeper config to point additional brokers at, so the setup steps differ: each node in a KRaft cluster needs its storage formatted with a shared cluster ID using the kafka-storage.sh tool, and node roles, broker, controller or both, are set directly in that node’s own properties file instead of being copied from a ZooKeeper connected template.
\nBecause this setup process genuinely changed rather than just moving a flag, I am not going to give you specific KRaft cluster commands here without the ability to verify them step by step against a live cluster. The official Apache Kafka quickstart documentation walks through the current KRaft multi broker setup with commands maintained directly by the Kafka project, and is the more reliable source to follow for this specific case.
\nThe screenshots below are kept from the original tutorial as a reference for the ZooKeeper era process, useful for understanding the shape of the older approach, but they should not be followed step by step on a current Kafka installation.<\/p>\n

\"Apache<\/strong><\/p>\n

Now edit these new files and set the following properties:<\/strong><\/p>\n

config\/server-one.properties<\/strong><\/p>\n

\"config\/server-one.properties\"<\/strong><\/p>\n

We already have Zookeeper and our single node started, so we just need to start the two new nodes<\/strong><\/p>\n

bin\/Kafka-server-start.sh config\/server-one.properties<\/strong><\/p>\n

\"config\/server-one.properties<\/strong><\/p>\n

Now create a new topic with a replication factor of three:<\/strong><\/p>\n

bin\/Kafka-topics.sh –create –zookeeper localhost:2181 –replication-factor 2 –partitions 1 –topic\u00a0Multibrokerapplication<\/strong><\/p>\n

\"config\/server-one.properties<\/strong><\/p>\n

bin\/Kafka-topics.sh –describe –zookeeper localhost:2181 –topic\u00a0Multibrokerapplication<\/strong><\/p>\n

\"replication<\/strong><\/p>\n

bin\/kafka-console-producer.sh –broker-list localhost:9092 –topic\u00a0Multibrokerapplication<\/strong><\/p>\n

\"broker-list<\/strong><\/p>\n

bin\/kafka-console-consumer.sh –bootstrap-server localhost:9092 –from-beginning –topic\u00a0Multibrokerapplication<\/strong><\/p>\n

\u00a0\"bootstrap-server<\/strong><\/p>\n

Case 4: Deleting a Topic<\/h3>\n

The live page shows three screenshots for this case but never actually gives the delete command itself. To delete a topic:<\/p>\n

bin\/kafka-topics.sh –>delete –>bootstrap-server localhost:9092 –>topic Multibrokerapplication<\/p>\n

Note that topic deletion needs to be enabled on the broker, through the delete.topic.enable setting, which defaults to true in current Kafka versions. If a delete appears to do nothing, this setting is the first thing to check.<\/p>\n

\"Deleting<\/strong><\/p>\n

\"Deleting<\/strong><\/p>\n

\"Deleting<\/strong><\/p>\n

Common Mistakes to Avoid<\/h2>\n
    \n
  • Using –zookeeper on a current Kafka install. It no longer exists as of Kafka 4.0. Use –bootstrap-server for every topic management command.<\/li>\n
  • Setting a replication factor higher than your number of running brokers. Kafka cannot replicate a topic across more brokers than actually exist, and will reject the request outright.<\/li>\n
  • Producing to one topic name and consuming from another. It sounds obvious written out, but a small typo in a topic name is one of the most common reasons a consumer appears to receive nothing.<\/li>\n<\/ul>\n

    Copying commands from an old tutorial or slide deck without checking the flags against your installed Kafka version. Kafka’s command line tools have changed meaningfully over the years, and a command that worked in an older training video may no longer work today.<\/p>\n