In this example we will implement custom records deserializer. We will use for that mechanism provided in Apache Kafka native driver. We will deserialize data from one of the most popular data format - JSON into some simple DTO Java class.

In this example, we will run the application that continuously reads data from a Kafka topic. When the application reaches the last offset, we will move the offset to the beginning of the topic. To make the experiment a little more complicated, we will simulate a random application crash and check the application's behavior after the crash.

In this task, we will implement a custom Partitioner for a Kafka Producer, as well as a Producer Interceptor. The objective is to enhance the functionality of the Kafka Producer by creating a tailored approach to message distribution and interception.

In this exercise, participants will explore the fundamental concepts of Kafka Topic Partitions, Consumer Group Offsets and message production and consumption. You will implement a custom Kafka producer and consumer, gaining hands-on experience in managing data flows and consumer groups, particularly in the context of handling multiple partitions. By following a structured series of steps, you will, create a topic with multiple partitions, and implement functionality to produce and consume messages efficiently across these partitions. This task will deepen your understanding of distributed messaging systems, enhance your skills in utilizing Kafka, demonstrate the benefits of partitioning for scalability and performance.

In this exercise, we will explore the fundamental Enterprise Integration Pattern - Publish/Subscribe. You will implement a custom Kafka producer and consumer, gaining hands-on experience with Kafka. This is very easy, starting point for everyone who likes to star play with Kafka.

Work in progress...

In this exercise, participants will gain hands-on experience with Apache Kafka, a powerful distributed streaming platform, using its Command Line Interface (CLI). Through a series of practical tasks, you will create topics, publish and consume messages, and explore key Kafka concepts such as partitions and consumer groups. The Kafka CLI provides essential tools for managing and interacting with your Kafka environment, enabling you to effectively monitor and control message flow. This session aims to enhance your understanding of Kafka’s architecture and its message processing capabilities, equipping you with the skills to leverage Kafka in real-world applications

A starting point, the simplest way to send messages to Kafka and poll messages from Kafka

In this exercise we build an application designed to aggregate text messages sent to recipients. We would like to store all messages sent to single user in unique aggregate.

Work in progress...

In this exercise we implement an application designed to count the number of text messages sent to recipients.