9hJSSKJr SSKJrJrJr SSKJrJ r "SS\5r g))Consumer) ConsumeErrorKeyDeserializationErrorValueDeserializationError)SerializationContext MessageFieldcF^\rSrSrSrU4SjrSU4SjjrSSjrSrU=r $) DeserializingConsumera A high level Kafka consumer with deserialization capabilities. `This class is experimental and likely to be removed, or subject to incompatible API changes in future versions of the library. To avoid breaking changes on upgrading, we recommend using deserializers directly.` Derived from the :py:class:`Consumer` class, overriding the :py:func:`Consumer.poll` method to add deserialization capabilities. Additional configuration properties: +-------------------------+---------------------+-----------------------------------------------------+ | Property Name | Type | Description | +=========================+=====================+=====================================================+ | | | Callable(bytes, SerializationContext) -> obj | | ``key.deserializer`` | callable | | | | | Deserializer used for message keys. | +-------------------------+---------------------+-----------------------------------------------------+ | | | Callable(bytes, SerializationContext) -> obj | | ``value.deserializer`` | callable | | | | | Deserializer used for message values. | +-------------------------+---------------------+-----------------------------------------------------+ Deserializers for string, integer and double (:py:class:`StringDeserializer`, :py:class:`IntegerDeserializer` and :py:class:`DoubleDeserializer`) are supplied out-of-the-box in the ``confluent_kafka.serialization`` namespace. Deserializers for Protobuf, JSON Schema and Avro (:py:class:`ProtobufDeserializer`, :py:class:`JSONDeserializer` and :py:class:`AvroDeserializer`) with Confluent Schema Registry integration are supplied out-of-the-box in the ``confluent_kafka.schema_registry`` namespace. See Also: - The :ref:`Configuration Guide ` for in depth information on how to configure the client. - `CONFIGURATION.md `_ for a comprehensive set of configuration properties. - `STATISTICS.md `_ for detailed information on the statistics provided by stats_cb - The :py:class:`Consumer` class for inherited methods. Args: conf (dict): DeserializingConsumer configuration. Raises: ValueError: if configuration validation fails c>UR5nURSS5UlURSS5Ul[[ U]U5 g)Nzkey.deserializerzvalue.deserializer)copypop_key_deserializer_value_deserializersuperr __init__)selfconf conf_copy __class__s kC:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\confluent_kafka/deserializing_consumer.pyrDeserializingConsumer.__init__IsFIIK !*/A4!H#,==1Et#L  #T3I>c>[[U] U5nUcgUR5b[ UR5US9e[ UR 5[RUR55nUR5nURbURXC5nUR5n[RUlUR"bUR#Xc5nUR'U5 UR)U5 U$![an[XRS9eSnAff=f![an[%XRS9eSnAff=f)a Consume messages and calls callbacks. Args: timeout (float): Maximum time to block waiting for message(Seconds). Returns: :py:class:`Message` or None on timeout Raises: KeyDeserializationError: If an error occurs during key deserialization. ValueDeserializationError: If an error occurs during value deserialization. ConsumeError: If an error was encountered while polling. N) kafka_message) exceptionr)rr pollerrorrrtopicr VALUEheadersvaluer ExceptionrkeyKEYfieldrrset_key set_value)rtimeoutmsgctxr#ser%rs rrDeserializingConsumer.pollPs#$)45g> ; 99; "syy{#> >"399; 0B0BCKKMR   # # / Q00<ggi $$  ! ! - O,,S6 C e  Q/"PP Q O-NN Os0DD+ D( D##D(+ E5 D>>Ec[e)z` :py:func:`Consumer.consume` not implemented, use :py:func:`DeserializingConsumer.poll` instead )NotImplementedError)r num_messagesr*s rconsumeDeserializingConsumer.consume~s "!r)rr))rr4) __name__ __module__ __qualname____firstlineno____doc__rrr2__static_attributes__ __classcell__)rs@rr r s+Z?,\""rr N) confluent_kafka.cimplr _ConsumerImplrrrr serializationrr r rrr@s'&<//*i"Mi"r