fix

Author: rohitsanj

src/confluent_kafka/schema_registry/_async/protobuf.py

@@ -30,7 +30,7 @@
                                              reference_subject_name_strategy,
                                              topic_subject_name_strategy,
                                              prefix_schema_id_serializer, dual_schema_id_deserializer)
-from confluent_kafka.schema_registry.schema_registry_client import SchemaRegistryClient
+from confluent_kafka.schema_registry.schema_registry_client import AsyncSchemaRegistryClient
 from confluent_kafka.schema_registry.common.protobuf import _bytes, _create_index_array, \
     _init_pool, _is_builtin, _schema_to_str, _str_to_proto, transform, _ContextStringIO, PROTOBUF_TYPE
 from confluent_kafka.schema_registry.rule_registry import RuleRegistry

src/confluent_kafka/schema_registry/common/protobuf.py

@@ -40,8 +40,8 @@
     'get_inline_tags',
     '_disjoint',
     '_is_builtin',
-    'decimalToProtobuf',
-    'protobufToDecimal'
+    'decimal_to_protobuf',
+    'protobuf_to_decimal'
 ]
 
 # Convert an int to bytes (inverse of ord())

src/confluent_kafka/schema_registry/common/schema_registry_client.py

@@ -23,7 +23,7 @@
 from enum import Enum
 from threading import Lock
 from typing import List, Dict, Type, TypeVar, \
-    cast, Optional, Any
+    cast, Optional, Any, Tuple
 
 __all__ = [
     'VALID_AUTH_PROVIDERS',