Skip to content

Trendyol/otel-kafka-konsumer

Repository files navigation

Otel Kafka Konsumer

This library enables distributed tracing on the segmentio/kafka-go library and is used on kafka-konsumer. You can use it without integration kafka-konsumer.

Please refer to example to learn how to use it. You can also look at the open-telemetry go documentation

Demo

In the examples, you can run

docker-compose up --build

Producing

Producing Example

Consuming

Consuming Example

Consuming With Manual Commit

Consuming Example

Bring it all together

You can run producer and consumer, respectively, to see that they work together.

Producing - Consuming Together