opentelemetry-python-contrib
opentelemetry-python-contrib copied to clipboard
Published
20 hours ago •
open-telemetry
open-telemetry
aiokafka instrumentation
trafficstars
Describe your environment
OS: windows + docker Python version: (e.g., Python 3.11) Package version: opentelemetry-instrumentation-aiokafka~=0.52b0 aiokafka~=0.12.0
What happened?
Exception: AIOKafkaProducer.send() got multiple values for argument 'headers'
Steps to Reproduce
Using opentelemetry-instrumentation-aiokafka~=0.52b0, from opentelemetry.instrumentation.aiokafka import AIOKafkaInstrumentor
Instrument kafka
AIOKafkaInstrumentor().instrument()
and await producer.send_and_wait(RESULTS_TOPIC, key=correlation_id, value=result_event.encode('utf-8'),)
Expected Result
Send event
Actual Result
Exception: AIOKafkaProducer.send() got multiple values for argument 'headers'
Additional context
No response
Would you like to implement a fix?
None
