From 71b21a9e643bc88eee8d2bfbbc66f15db7d122a4 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Sergio=20G=C3=B3mez=20Villamor?= Date: Wed, 3 Sep 2025 14:54:05 +0200 Subject: [PATCH] chore(kafka): fixes lower bound version for confluent_kafka dep in ingestion (#14630) --- metadata-ingestion/setup.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/metadata-ingestion/setup.py b/metadata-ingestion/setup.py index 2eedfad11e..85f6168c49 100644 --- a/metadata-ingestion/setup.py +++ b/metadata-ingestion/setup.py @@ -75,7 +75,8 @@ kafka_common = { # With the release of 2.8.1, confluent-kafka only released a source distribution, # and no prebuilt wheels. # See https://github.com/confluentinc/confluent-kafka-python/issues/1927 - "confluent_kafka[schemaregistry,avro]>=1.9.0, != 2.8.1", + # RegisteredSchema#guid is being used and was introduced in 2.10.1 https://github.com/confluentinc/confluent-kafka-python/pull/1978 + "confluent_kafka[schemaregistry,avro]>=2.10.1", # We currently require both Avro libraries. The codegen uses avro-python3 (above) # schema parsers at runtime for generating and reading JSON into Python objects. # At the same time, we use Kafka's AvroSerializer, which internally relies on