opensource/opentelemetry-python-contrib
1
0
Fork 0
mirror of https://github.com/open-telemetry/opentelemetry-python-contrib.git synced 2025-07-28 12:43:39 +08:00
Code Issues Packages Projects Releases Wiki Activity

conflent-kafka: Proxy producer purge (#2638)

Browse Source
This commit is contained in:
joshschltelus
2024-06-27 10:19:50 -07:00
committed by GitHub
parent 7f7c0f31fe
commit 58a6d3a79c
2 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
CHANGELOG.md
View File

@ -20,6 +20,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
([#2573](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/2573)) ([#2573](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/2573))
- `opentelemetry-instrumentation-confluent-kafka` Add support for version 2.4.0 of confluent_kafka - `opentelemetry-instrumentation-confluent-kafka` Add support for version 2.4.0 of confluent_kafka
([#2616](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/2616)) ([#2616](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/2616))
- `opentelemetry-instrumentation-confluent-kafka` Add support for produce purge
([#2638](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/2638))
### Breaking changes ### Breaking changes

3
instrumentation/opentelemetry-instrumentation-confluent-kafka/src/opentelemetry/instrumentation/confluent_kafka/__init__.py
View File

@ -156,6 +156,9 @@ class ProxiedProducer(Producer):
def poll(self, timeout=-1): def poll(self, timeout=-1):
return self._producer.poll(timeout) return self._producer.poll(timeout)
def purge(self, in_queue=True, in_flight=True, blocking=True):
self._producer.purge(in_queue, in_flight, blocking)
def produce( def produce(
self, topic, value=None, *args, **kwargs self, topic, value=None, *args, **kwargs
): # pylint: disable=keyword-arg-before-vararg ): # pylint: disable=keyword-arg-before-vararg