hfajkslfhsakdjhfsdakjhfa

rjduffner · rjduffner · commit a940efc8636f · 2026-07-10T14:36:10.000-07:00
diff --git a/.changelog/4785.added b/.changelog/4785.added
@@ -0,0 +1 @@
+Update kafka python to support kafka-python 3 and remove support for kafka-python-ng
diff --git a/instrumentation/opentelemetry-instrumentation-kafka-python/src/opentelemetry/instrumentation/kafka/__init__.py b/instrumentation/opentelemetry-instrumentation-kafka-python/src/opentelemetry/instrumentation/kafka/__init__.py
@@ -82,7 +82,6 @@ def process_msg(message):
 ---
 """
 
-from importlib.metadata import PackageNotFoundError, distribution
 from typing import Collection
 
 import kafka
diff --git a/uv.lock b/uv.lock

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1 @@`
	`1`	`+Update kafka python to support kafka-python 3 and remove support for kafka-python-ng`