/springKafka_Tracing

Trace Kafka messages with Spring Kafka and OpenTelemetry

Primary LanguageJava

spring-kafka-integration

Architecture

capture 1

Prerequisites

  • JDK 1.8
  • Maven 3.x
  • Docker

Run kafka container

In a terminal, run

docker-compose up -d

Run Producer

cd producer
java -jar target/producer-0.0.1-SNAPSHOT.jar

Run Consumer

cd consumer
java -jar target/consumer-0.0.1-SNAPSHOT.jar

Output

Go to http://localhost:8082/api and post a message via swagger ui.

tracing kafka message with Zipkin

capture 2