Skip to content

Latest commit

 

History

History
37 lines (25 loc) · 1.07 KB

README.md

File metadata and controls

37 lines (25 loc) · 1.07 KB

Kafka Streams Print

This module streams records of type <String, KafkaUser> from two topics: USER_TOPIC and USER_TOPIC_TWO, and prints each record to a file and the console, respectively. It demonstrates how to use the Kafka Streams DSL print().

topology.png

Prerequisites

To compile and run this demo, you’ll need:

  • 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 the USER_TOPIC and USER_TOPIC_TWO. You can use the Producer User for 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