diff --git a/src/confluent_kafka/avro/load.py b/src/confluent_kafka/avro/load.py
index e7709a115..112be6b74 100644
--- a/src/confluent_kafka/avro/load.py
+++ b/src/confluent_kafka/avro/load.py
@@ -23,10 +23,7 @@
 def loads(schema_str):
     """ Parse a schema given a schema string """
     try:
-        if sys.version_info[0] < 3:
-            return schema.parse(schema_str)
-        else:
-            return schema.Parse(schema_str)
+        return schema.parse(schema_str)
     except schema.SchemaParseException as e:
         raise ClientError("Schema parse failed: %s" % (str(e)))