From b099d408bd520ae5823ee867f05d791417d2bc3c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Pawe=C5=82=20Kozio=C5=82?= Date: Mon, 26 Jun 2023 16:11:31 +0200 Subject: [PATCH 1/2] Add missing import for SerializerError --- clients/cloud/python/consumer_ccsr.py | 1 + 1 file changed, 1 insertion(+) diff --git a/clients/cloud/python/consumer_ccsr.py b/clients/cloud/python/consumer_ccsr.py index d38b24832..690c67fe9 100755 --- a/clients/cloud/python/consumer_ccsr.py +++ b/clients/cloud/python/consumer_ccsr.py @@ -24,6 +24,7 @@ # ============================================================================= from confluent_kafka import DeserializingConsumer +from confluent_kafka.avro.serializer import SerializerError from confluent_kafka.schema_registry import SchemaRegistryClient from confluent_kafka.schema_registry.avro import AvroDeserializer from confluent_kafka.serialization import StringDeserializer From e6a51651094cb42e9101b431f777a0c10919b1d9 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Pawe=C5=82=20Kozio=C5=82?= Date: Mon, 26 Jun 2023 16:45:26 +0200 Subject: [PATCH 2/2] Update URL to DeserializingConsumer --- clients/cloud/python/consumer_ccsr.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/clients/cloud/python/consumer_ccsr.py b/clients/cloud/python/consumer_ccsr.py index 690c67fe9..ce3618433 100755 --- a/clients/cloud/python/consumer_ccsr.py +++ b/clients/cloud/python/consumer_ccsr.py @@ -54,7 +54,7 @@ from_dict = ccloud_lib.Count.dict_to_count) # for full list of configurations, see: - # https://docs.confluent.io/platform/current/clients/confluent-kafka-python/#deserializingconsumer + # https://docs.confluent.io/platform/current/clients/confluent-kafka-python/html/#deserializingconsumer-experimental consumer_conf = ccloud_lib.pop_schema_registry_params_from_config(conf) consumer_conf['key.deserializer'] = name_avro_deserializer consumer_conf['value.deserializer'] = count_avro_deserializer