9hFSSKJr SSKJrJr SSKJrJr "SS\5r g))Producer) MessageFieldSerializationContext)KeySerializationErrorValueSerializationErrorc@^\rSrSrSrU4SjrSU4SjjrSrU=r$)SerializingProduceraG A high level Kafka producer with serialization 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 serializers directly.` Derived from the :py:class:`Producer` class, overriding the :py:func:`Producer.produce` method to add serialization capabilities. Additional configuration properties: +-------------------------+---------------------+-----------------------------------------------------+ | Property Name | Type | Description | +=========================+=====================+=====================================================+ | | | Callable(obj, SerializationContext) -> bytes | | ``key.serializer`` | callable | | | | | Serializer used for message keys. | +-------------------------+---------------------+-----------------------------------------------------+ | | | Callable(obj, SerializationContext) -> bytes | | ``value.serializer`` | callable | | | | | Serializer used for message values. | +-------------------------+---------------------+-----------------------------------------------------+ Serializers for string, integer and double (:py:class:`StringSerializer`, :py:class:`IntegerSerializer` and :py:class:`DoubleSerializer`) are supplied out-of-the-box in the ``confluent_kafka.serialization`` namespace. Serializers for Protobuf, JSON Schema and Avro (:py:class:`ProtobufSerializer`, :py:class:`JSONSerializer` and :py:class:`AvroSerializer`) 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:`Producer` class for inherited methods. Args: conf (producer): SerializingProducer configuration. c>UR5nURSS5UlURSS5Ul[[ U]U5 g)Nzkey.serializerzvalue.serializer)copypop_key_serializer_value_serializersuperr __init__)selfconf conf_copy __class__s iC:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\confluent_kafka/serializing_producer.pyrSerializingProducer.__init__EsFIIK (}}-=tD!*/A4!H !41)<c >[U[RU5nURbURX(5n[R UlURbURX85n[[U]3XUUUUUS9 g![an [ U 5eSn A ff=f![an [U 5eSn A ff=f)a Produce a message. This is an asynchronous operation. An application may use the ``on_delivery`` argument to pass a function (or lambda) that will be called from :py:func:`SerializingProducer.poll` when the message has been successfully delivered or permanently fails delivery. Note: Currently message headers are not supported on the message returned to the callback. The ``msg.headers()`` will return None even if the original message had headers set. Args: topic (str): Topic to produce message to. key (object, optional): Message payload key. value (object, optional): Message payload value. partition (int, optional): Partition to produce to, else the configured built-in partitioner will be used. on_delivery (callable(KafkaError, Message), optional): Delivery report callback. Called as a side effect of :py:func:`SerializingProducer.poll` or :py:func:`SerializingProducer.flush` on successful or failed delivery. timestamp (float, optional): Message timestamp (CreateTime) in milliseconds since Unix epoch UTC (requires broker >= 0.10.0.0). Default value is current time. headers (dict, optional): Message headers. The header key must be a str while the value must be binary, unicode or None. (Requires broker version >= 0.11.0.0) Raises: BufferError: if the internal producer message queue is full. (``queue.buffering.max.messages`` exceeded). If this happens the application should call :py:func:`SerializingProducer.Poll` and try again. KeySerializationError: If an error occurs during key serialization. ValueSerializationError: If an error occurs during value serialization. KafkaException: For all other errors N)headers partition timestamp on_delivery) rrKEYr ExceptionrVALUEfieldrrrr produce) rtopickeyvaluerrrrctxsers rr#SerializingProducer.produceMsh#5,*:*:GD    + 0**34!&&  ! ! - 2..u: !40s9@;D;D=H 1 J 0+B// 0  2-b11 2s/BB$ B! BB!$ B>. B99B>)rr)NNNrN) __name__ __module__ __qualname____firstlineno____doc__rr#__static_attributes__ __classcell__)rs@rr r s%(T=>@7;EJEJrr N) confluent_kafka.cimplr _ProducerImpl serializationrrerrorrrr rrr7s$&<2-xJ-xJr