diff --git a/clients/cloud/python/consumer_ccsr.py b/clients/cloud/python/consumer_ccsr.py index d38b24832..ce3618433 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 @@ -53,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