bfncs/kafka-topic-record-name-strategy-poc

Kafka TopicRecordNameStrategy proof of concept

This repo contains a proof of concept using the subject name strategy setting TopicRecordNameStrategy (see documentation) in Kafka Java Producer and Consumer API.

Build

mvn clean package

Run

1. Start Kafka Broker, Zookeeper and Schema Registry locally. The quickest way is to use Landoop/fast-data-dev:

   docker run --rm --net=host landoop/fast-data-dev

2. Start the producer application:

   java -jar ./target/producer-app.jar

3. Start the consumer application:

   java -jar ./target/consumer-app.jar