Java Consumer and Producer Messages Between Kafka Server [Video Tutorials]
This video tutorial series explores the procedure of sending and receiving messages between a Java consumer and producer and the Apache Kafka server.
Join the DZone community and get the full member experience.
Join For FreeThroughout this series of video tutorials, we will explore the procedure of sending and receiving messages between a Java consumer and producer and the Apache Kafka server.
Java Consumer Code to Consume Messages From Apache Kafka Server
This video tutorial explains how to write a consumer that will consume messages from a Kafka Server installed in the Amazon EC2 Instance.
Kafka Producer Send Messages to a Single Topic Partition
Explore how Kafka producer sends all messages to a single selected partition by:
- The producer can select the partition of their choice in a topic where the producer wants to publish the message.
- All the messages will be published to a single partition (P0).
- The product can send messages to the selected partition. We have to pass the partition number and the key.
Java Product Code to Send Messages to the Apache Server Installed in the Amazon EC2 Instance
In this tutorial video, you will discover the process of writing producer code in Java. This code will enable you to send messages to a Kafka server that has been deployed on an Amazon EC2 instance.
Java Producer and Consumer Code to Send/Receive messages To/From the Apache Kafka Server (EC2 Instance)
Learn how to utilize Java producer and consumer code to send and receive messages to and from the Apache Kafka server (EC2 Instance).
Java Program to Send Custom Object Into Kafka Topic and Consume Custom Object From Kafka Topic
Here is a Java program that allows you to send a custom object to a Kafka topic and also consumes a custom object from a Kafka topic.
Java Program to Send/Consume Custom Object Into/From Kafka Server Running on Amazon EC2 Instance
Next, you can learn how to utilize a Java program to send either a JSON object or a custom object to a Kafka topic. Additionally, you will also be guided on how to consume a JSON object or a custom object from a Kafka topic.
Opinions expressed by DZone contributors are their own.
Comments