opentelemetry_kafka_python_producer_consumer_tracing_quickstart.py

1from kafka import KafkaProducer, KafkaConsumer
2from opentelemetry.instrumentation.kafka_python import KafkaInstrumentor
3
4# 1. Initialize the KafkaInstrumentor
5# This must be called before the Kafka clients are initialized
6KafkaInstrumentor().instrument()
7
8# 2. Example Kafka Producer
9producer = KafkaProducer(bootstrap_servers=['localhost:9092'])
10producer.send('my-topic', b'Hello, OpenTelemetry!')
11producer.flush()
12
13# 3. Example Kafka Consumer
14consumer = KafkaConsumer('my-topic', bootstrap_servers=['localhost:9092'])
15for message in consumer:
16    print(f"Received: {message.value}")
17    # The instrumentation automatically handles span propagation
18    break