2Bf~ddlZddlZ ddlZddlmZej dZGddeZy#e$rdZY-wxYw)N) PubSubManagersocketioc>eZdZdZdZ dfd ZdZdZdZxZ S) KafkaManageraIKafka based client manager. This class implements a Kafka backend for event sharing across multiple processes. To use a Kafka backend, initialize the :class:`Server` instance as follows:: url = 'kafka://hostname:port' server = socketio.Server(client_manager=socketio.KafkaManager(url)) :param url: The connection URL for the Kafka server. For a default Kafka store running on the same host, use ``kafka://``. :param channel: The channel name (topic) on which the server sends and receives notifications. Must be the same in all the servers. :param write_only: If set to ``True``, only initialize to emit events. The default of ``False`` initializes the class for emitting and receiving. kafkact tdtt||||dk7r|ddnd|_tj |j |_tj|j|j |_ y)NzZkafka-python package is not installed (Run "pip install kafka-python" in your virtualenv).)channel write_onlyzkafka://zlocalhost:9092)bootstrap_servers) r RuntimeErrorsuperr__init__ kafka_url KafkaProducerproducer KafkaConsumerr consumer)selfurlr r __class__s V/var/www/highfloat_scraper/venv/lib/python3.12/site-packages/socketio/kafka_manager.pyrzKafkaManager.__init__%s = ./ / lD*76@ + B%(:$5QR;K++dnnM ++DLL>BnnN c|jj|jtj||jj y)N)value)rsendr pickledumpsflush)rdatas r_publishzKafkaManager._publish4s6 4<r8sL *   : &12=12 Es 2<<