kafka-streams-print

Kafka Streams Print

This module demonstrates the usage of the Kafka Streams DSL print() and peek().

In this module, records of type <String, KafkaUser> are streamed from two topics named USER_TOPIC and USER_TOPIC_TWO. The following tasks are performed:

1. Stream records of type <String, KafkaUser> from the topic USER_TOPIC and print them to the file /tmp/kafka-streams-quickstarts/streams-print-output.log.
2. Stream records of type <String, KafkaUser> from the topic USER_TOPIC_TWO and print them to the system output.

Prerequisites

To compile and run this demo, you will need the following:

• Java 21
• Maven
• Docker

Running the Application

To run the application manually:

• Start a Confluent Platform in a Docker environment.
• Produce records of type <String, KafkaUser> to topics named USER_TOPIC and USER_TOPIC_TWO. You can use the producer user to do this.
• Start the Kafka Streams application.

To run the application in Docker, use the following command:

docker-compose up -d

This command will start the following services in Docker:

• 1 Kafka broker (KRaft mode)
• 1 Schema registry
• 1 Control Center
• 1 producer User
• 1 Kafka Streams Print