Backport recent _sync changes into _async/protobuf.py (#1987)

Author: rohitsanj

src/confluent_kafka/schema_registry/_async/protobuf.py

@@ -16,7 +16,6 @@
 # limitations under the License.
 
 import io
-import warnings
 from typing import Set, List, Union, Optional, Tuple
 
 from google.protobuf import json_format, descriptor_pb2
@@ -149,18 +148,6 @@ class AsyncProtobufSerializer(AsyncBaseSerializer):
     | ``schema.id.serializer``            | callable | Defines how the schema id/guid is serialized.        |
     |                                     |          | Defaults to prefix_schema_id_serializer.             |
     +-------------------------------------+----------+------------------------------------------------------+
-    | ``use.deprecated.format``           | bool     | Specifies whether the Protobuf serializer should     |
-    |                                     |          | serialize message indexes without zig-zag encoding.  |
-    |                                     |          | This option must be explicitly configured as older   |
-    |                                     |          | and newer Protobuf producers are incompatible.       |
-    |                                     |          | If the consumers of the topic being produced to are  |
-    |                                     |          | using confluent-kafka-python <1.8 then this property |
-    |                                     |          | must be set to True until all old consumers have     |
-    |                                     |          | have been upgraded.                                  |
-    |                                     |          |                                                      |
-    |                                     |          | Warning: This configuration property will be removed |
-    |                                     |          | in a future version of the client.                   |
-    +-------------------------------------+----------+------------------------------------------------------+
 
     Schemas are registered against subject names in Confluent Schema Registry that
     define a scope in which the schemas can be evolved. By default, the subject name
@@ -260,14 +247,7 @@ async def __init__(
         if not isinstance(self._use_deprecated_format, bool):
             raise ValueError("use.deprecated.format must be a boolean value")
         if self._use_deprecated_format:
-            warnings.warn("ProtobufSerializer: the 'use.deprecated.format' "
-                          "configuration property, and the ability to use the "
-                          "old incorrect Protobuf serializer heading format "
-                          "introduced in confluent-kafka-python v1.4.0, "
-                          "will be removed in an upcoming release in 2021 Q2. "
-                          "Please migrate your Python Protobuf producers and "
-                          "consumers to 'use.deprecated.format':False as "
-                          "soon as possible")
+            raise ValueError("use.deprecated.format is no longer supported")
 
         self._subject_name_func = conf_copy.pop('subject.name.strategy')
         if not callable(self._subject_name_func):
@@ -499,17 +479,6 @@ class AsyncProtobufDeserializer(AsyncBaseDeserializer):
     | ``schema.id.deserializer``          | callable | Defines how the schema id/guid is deserialized.      |
     |                                     |          | Defaults to dual_schema_id_deserializer.             |
     +-------------------------------------+----------+------------------------------------------------------+
-    | ``use.deprecated.format``           | bool     | Specifies whether the Protobuf deserializer should   |
-    |                                     |          | deserialize message indexes without zig-zag encoding.|
-    |                                     |          | This option must be explicitly configured as older   |
-    |                                     |          | and newer Protobuf producers are incompatible.       |
-    |                                     |          | If Protobuf messages in the topic to consume were    |
-    |                                     |          | produced with confluent-kafka-python <1.8 then this  |
-    |                                     |          | property must be set to True until all old messages  |
-    |                                     |          | have been processed and producers have been upgraded.|
-    |                                     |          | Warning: This configuration property will be removed |
-    |                                     |          | in a future version of the client.                   |
-    +-------------------------------------+----------+------------------------------------------------------+
 
 
     See Also:
@@ -566,14 +535,7 @@ async def __init__(
         if not isinstance(self._use_deprecated_format, bool):
             raise ValueError("use.deprecated.format must be a boolean value")
         if self._use_deprecated_format:
-            warnings.warn("ProtobufDeserializer: the 'use.deprecated.format' "
-                          "configuration property, and the ability to use the "
-                          "old incorrect Protobuf serializer heading format "
-                          "introduced in confluent-kafka-python v1.4.0, "
-                          "will be removed in an upcoming release in 2022 Q2. "
-                          "Please migrate your Python Protobuf producers and "
-                          "consumers to 'use.deprecated.format':False as "
-                          "soon as possible")
+            raise ValueError("use.deprecated.format is no longer supported")
 
         descriptor = message_type.DESCRIPTOR
         self._msg_class = GetMessageClass(descriptor)