diff --git a/pulsar-client-cpp/python/pulsar/schema/schema_avro.py b/pulsar-client-cpp/python/pulsar/schema/schema_avro.py index d2b57cb621323..e76fc51affbe8 100644 --- a/pulsar-client-cpp/python/pulsar/schema/schema_avro.py +++ b/pulsar-client-cpp/python/pulsar/schema/schema_avro.py @@ -59,7 +59,7 @@ def encode(self, obj): fastavro.schemaless_writer(buffer, self._schema, m) return buffer.getvalue() - def encode_dict(self, d: dict): + def encode_dict(self, d): obj = {} for k, v in d.items(): obj[k] = self._get_serialized_value(v)