aiokafka instrumentation

[elghali]

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

[fcfangcc]

#3332 I am trying to fix this bug and waiting for merge. Perhaps someone can improve the PR

@elghali headers=[] can skip this bug

await producer.send_and_wait(RESULTS_TOPIC, key=correlation_id, value=result_event.encode('utf-8'),headers=[])

[elghali]

@fcfangcc thank you for the tip, however does this affect the traces collecting?

[fcfangcc]

@fcfangcc thank you for the tip, however does this affect the traces collecting?

It won't affect the traces collecting. This usage is just to avoid triggering a logical bug in the instrumentation.