You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Describe your environment
Python 3.8
confluent-kafka[avro]==1.9.2
opentelemetry-instrumentation-confluent-kafka==0.35b0
Steps to reproduce
Call ProxiedConsumer.commit
What is the expected behavior?
Message is committed in Kafka cluster
What is the actual behavior?
Get an exception with message "Consumer closed"
Additional context
ProxiedConsumer is not an actual Consumer but using a private internal Consumer instance to do poll, consume, etc. It is missing an over-ridden version of ProxiedConsumer.commit which calls the private Consumer's commit.
The text was updated successfully, but these errors were encountered:
Describe your environment
Python 3.8
confluent-kafka[avro]==1.9.2
opentelemetry-instrumentation-confluent-kafka==0.35b0
Steps to reproduce
Call ProxiedConsumer.commit
What is the expected behavior?
Message is committed in Kafka cluster
What is the actual behavior?
Get an exception with message "Consumer closed"
Additional context
ProxiedConsumer is not an actual Consumer but using a private internal Consumer instance to do poll, consume, etc. It is missing an over-ridden version of ProxiedConsumer.commit which calls the private Consumer's commit.
The text was updated successfully, but these errors were encountered: