{"id":577,"date":"2019-03-01T09:36:52","date_gmt":"2019-03-01T09:36:52","guid":{"rendered":"https:\/\/prwatech.in\/blog\/?p=577"},"modified":"2024-04-02T09:40:04","modified_gmt":"2024-04-02T09:40:04","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

 <\/p>\n

Apache Kafka Use Case Tutorial<\/strong>, Welcome to the world of advanced Tutorials on the use case for apache spark<\/a>. 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<\/a> experts who offer Advanced advanced Apache spark training<\/a>. Follow the below-mentioned Apache spark use case tutorial and enhance your skills to become a professional Spark Developer<\/a>.<\/p>\n

Apache Kafka Use Case Examples<\/h2>\n

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

Create one topic test<\/strong><\/p>\n

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

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

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

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

Write your message\u00a0<\/strong><\/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

You will get the message from producer<\/strong><\/p>\n

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

Case 2. Two producers and One consumer<\/strong><\/h3>\n

Create another topic Multibrokerapplication<\/strong><\/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<\/strong><\/h3>\n

let’s expand our cluster to 2 nodes (still all on our local machine)<\/strong><\/p>\n

cp config\/server.properties config\/server.properties<\/strong><\/p>\n

cp config\/server.properties config\/server-one.properties<\/strong><\/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:-\u00a0 Deleting topic form list<\/strong><\/h3>\n

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

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

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

We hope you understand Apache spark Use Case tutorial with examples concepts. Get success in your career as a Spark Developer<\/a> by being a part of the Prwatech<\/a>, India’s leading Apache Spark training institute in Bangalore<\/a>.<\/p>\n