diff --git a/pulsar/schema/schema_avro.py b/pulsar/schema/schema_avro.py index 05ceb8e..3e629fb 100644 --- a/pulsar/schema/schema_avro.py +++ b/pulsar/schema/schema_avro.py @@ -85,7 +85,7 @@ def decode(self, data): else: class AvroSchema(Schema): - def __init__(self, _record_cls, _schema_definition): + def __init__(self, _record_cls, _schema_definition=None): raise Exception("Avro library support was not found. Make sure to install Pulsar client " + "with Avro support: pip3 install 'pulsar-client[avro]'")