Skip to content

Latest commit

 

History

History
39 lines (26 loc) · 1.12 KB

README.md

File metadata and controls

39 lines (26 loc) · 1.12 KB

Kafka Streams Select Key

This module streams records of type <String, KafkaUser> from the USER_TOPIC and selects the last name of each record as the new key. It demonstrates the following:

  • How to use the Kafka Streams DSL, including selectKey() and peek().
  • Unit testing using the Topology Test Driver.

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. 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 Select Key