feat: Update opentelemetry-instrumentation-confluent-kafka to support confluent-kafka <=2.11.0 (#3685)

papigers · web-flow · commit c6b14fcd4dda · 2025-08-22T15:06:45.000Z
* feat: Update opentelemetry-instrumentation-confluent-kafka to support confluent-kafka &lt;=2.11.0

* changelog

* cr

* fixes + uv lock
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -16,6 +16,11 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - `opentelemetry-instrumentation`: Avoid calls to `context.detach` with `None` token.
   ([#3673](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/3673))
 
+### Added
+
+- `opentelemetry-instrumentation-confluent-kafka` Add support for confluent-kafka <=2.11.0
+  ([#3685](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/3685))
+
 ## Version 1.36.0/0.57b0 (2025-07-29)
 
 ### Fixed
@@ -116,7 +121,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 ### Deprecated
 
 - Drop support for Python 3.8, bump baseline to Python 3.9.
-([#3399](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/3399))
+  ([#3399](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/3399))
 
 ## Version 1.33.0/0.54b0 (2025-05-09)
 
diff --git a/docs-requirements.txt b/docs-requirements.txt
@@ -21,7 +21,7 @@ botocore~=1.0
 boto3~=1.0
 cassandra-driver~=3.25
 celery>=4.0
-confluent-kafka>= 1.8.2,<= 2.4.0
+confluent-kafka>= 1.8.2,<= 2.11.0
 elasticsearch>=6.0,<9.0
 flask~=2.0
 falcon~=2.0
diff --git a/instrumentation/README.md b/instrumentation/README.md
@@ -17,7 +17,7 @@
 | [opentelemetry-instrumentation-cassandra](./opentelemetry-instrumentation-cassandra) | cassandra-driver ~= 3.25,scylla-driver ~= 3.25 | No | development
 | [opentelemetry-instrumentation-celery](./opentelemetry-instrumentation-celery) | celery >= 4.0, < 6.0 | No | development
 | [opentelemetry-instrumentation-click](./opentelemetry-instrumentation-click) | click >= 8.1.3, < 9.0.0 | No | development
-| [opentelemetry-instrumentation-confluent-kafka](./opentelemetry-instrumentation-confluent-kafka) | confluent-kafka >= 1.8.2, <= 2.7.0 | No | development
+| [opentelemetry-instrumentation-confluent-kafka](./opentelemetry-instrumentation-confluent-kafka) | confluent-kafka >= 1.8.2, <= 2.11.0 | No | development
 | [opentelemetry-instrumentation-dbapi](./opentelemetry-instrumentation-dbapi) | dbapi | No | development
 | [opentelemetry-instrumentation-django](./opentelemetry-instrumentation-django) | django >= 1.10 | Yes | development
 | [opentelemetry-instrumentation-elasticsearch](./opentelemetry-instrumentation-elasticsearch) | elasticsearch >= 6.0 | No | development
diff --git a/instrumentation/opentelemetry-instrumentation-confluent-kafka/pyproject.toml b/instrumentation/opentelemetry-instrumentation-confluent-kafka/pyproject.toml
@@ -32,7 +32,7 @@ dependencies = [
 
 [project.optional-dependencies]
 instruments = [
-  "confluent-kafka >= 1.8.2, <= 2.7.0",
+  "confluent-kafka >= 1.8.2, <= 2.11.0",
 ]
 
 [project.entry-points.opentelemetry_instrumentor]
diff --git a/instrumentation/opentelemetry-instrumentation-confluent-kafka/src/opentelemetry/instrumentation/confluent_kafka/package.py b/instrumentation/opentelemetry-instrumentation-confluent-kafka/src/opentelemetry/instrumentation/confluent_kafka/package.py
@@ -13,4 +13,4 @@
 # limitations under the License.
 
 
-_instruments = ("confluent-kafka >= 1.8.2, <= 2.7.0",)
+_instruments = ("confluent-kafka >= 1.8.2, <= 2.11.0",)
diff --git a/instrumentation/opentelemetry-instrumentation-confluent-kafka/test-requirements.txt b/instrumentation/opentelemetry-instrumentation-confluent-kafka/test-requirements.txt
@@ -1,5 +1,5 @@
 asgiref==3.8.1
-confluent-kafka==2.6.1
+confluent-kafka==2.11.0
 Deprecated==1.2.14
 iniconfig==2.0.0
 packaging==24.0
diff --git a/opentelemetry-instrumentation/src/opentelemetry/instrumentation/bootstrap_gen.py b/opentelemetry-instrumentation/src/opentelemetry/instrumentation/bootstrap_gen.py
@@ -85,7 +85,7 @@
         "instrumentation": "opentelemetry-instrumentation-click==0.58b0.dev",
     },
     {
-        "library": "confluent-kafka >= 1.8.2, <= 2.7.0",
+        "library": "confluent-kafka >= 1.8.2, <= 2.11.0",
         "instrumentation": "opentelemetry-instrumentation-confluent-kafka==0.58b0.dev",
     },
     {
diff --git a/uv.lock b/uv.lock

Original file line number	Diff line number	Diff line change
`@@ -32,7 +32,7 @@ dependencies = [`
`32`	`32`
`33`	`33`	`[project.optional-dependencies]`
`34`	`34`	`instruments = [`
`35`		`- "confluent-kafka >= 1.8.2, <= 2.7.0",`
	`35`	`+ "confluent-kafka >= 1.8.2, <= 2.11.0",`
`36`	`36`	`]`
`37`	`37`
`38`	`38`	`[project.entry-points.opentelemetry_instrumentor]`
Original file line number	Diff line number	Diff line change
`@@ -13,4 +13,4 @@`
`13`	`13`	`# limitations under the License.`
`14`	`14`
`15`	`15`
`16`		`-_instruments = ("confluent-kafka >= 1.8.2, <= 2.7.0",)`
	`16`	`+_instruments = ("confluent-kafka >= 1.8.2, <= 2.11.0",)`
Original file line number	Diff line number	Diff line change
`@@ -85,7 +85,7 @@`
`85`	`85`	`"instrumentation": "opentelemetry-instrumentation-click==0.58b0.dev",`
`86`	`86`	`},`
`87`	`87`	`{`
`88`		`- "library": "confluent-kafka >= 1.8.2, <= 2.7.0",`
	`88`	`+ "library": "confluent-kafka >= 1.8.2, <= 2.11.0",`
`89`	`89`	`"instrumentation": "opentelemetry-instrumentation-confluent-kafka==0.58b0.dev",`
`90`	`90`	`},`
`91`	`91`	`{`