Skip to content

Commit e7e9c75

Browse files
committed
Add TODO to simpligy the instrumentation
1 parent f5146ce commit e7e9c75

1 file changed

Lines changed: 3 additions & 0 deletions

File tree

  • instrumentation/opentelemetry-instrumentation-confluent-kafka/src/opentelemetry/instrumentation/confluent_kafka

instrumentation/opentelemetry-instrumentation-confluent-kafka/src/opentelemetry/instrumentation/confluent_kafka/__init__.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -277,6 +277,9 @@ def instrumentation_dependencies(self) -> Collection[str]:
277277
return _instruments
278278

279279
def _instrument(self, **kwargs):
280+
# TODO: should probably wrap methods directly instead of going through
281+
# these classes. Hopefully it'll make the patching work if called after
282+
# the original classes have already been imported
280283
self._original_kafka_producer = confluent_kafka.Producer
281284
self._original_kafka_consumer = confluent_kafka.Consumer
282285

0 commit comments

Comments
 (0)