opentelemetry-instrumentation-confluent-kafka: TypeError on consumer close

[allistergg]

Describe your environment

OS: Fedora
Python version: 3.12.4
Package version:
confluent-kafka==2.4.0
opentelemetry-distro==0.48b0
opentelemetry-instrumentation-confluent-kafka==0.48b0

What happened?

on consumer.close()
TypeError: ConfluentKafkaInstrumentor._instrument.<locals>._inner_wrap_close() takes 2 positional arguments but 4 were given

Steps to Reproduce

consumer.py:

from confluent_kafka import Consumer

topic = "topic"

consumer = Consumer({'bootstrap.servers': 'localhost:9092', 'group.id': 'test-group'})
consumer.subscribe([topic])
message = consumer.poll(timeout=5)
consumer.close()

$ opentelemetry-instrument python consumer.py

Expected Result

No TypeError

Actual Result

TypeError: ConfluentKafkaInstrumentor._instrument.<locals>._inner_wrap_close() takes 2 positional arguments but 4 were given

Additional context

No response

Would you like to implement a fix?

None

[Gallardot]

environment

OS: Mac OS
Python version: 3.9
Package version:
confluent-kafka                               2.6.1
opentelemetry-instrumentation-confluent-kafka 0.51b0

example code

from opentelemetry.instrumentation.confluent_kafka import ConfluentKafkaInstrumentor
ConfluentKafkaInstrumentor().instrument()
from confluent_kafka import Consumer
topic = "topic"
consumer = Consumer({'bootstrap.servers': 'localhost:9092', 'group.id': 'test-group'})
consumer.subscribe([topic])
message = consumer.poll(timeout=5)
consumer.close()

got the same error

consumer.close()
TypeError: _inner_wrap_close() takes 2 positional arguments but 4 were given

I will try to fix it

[Gallardot]

After tested, I think #3922 have fixed it.

[xrmx]

@Gallardot thanks for checking that!