wgT ~ddlZddlZ ddlZddlmZej dZGddeZy#e$rdZY-wxYw)N) PubSubManagersocketioc>eZdZdZdZ dfd ZdZdZdZxZ S) KafkaManageraKafka 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://``. For a highly available deployment of Kafka, pass a list with all the connection URLs available in your cluster. :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. kafkacft tdt| ||t |t r|gn|}|Dcgc]}|dk7r|ddndc}|_tj|j |_tj|j|j |_ ycc}w)NzZkafka-python package is not installed (Run "pip install kafka-python" in your virtualenv).)channel write_onlyzkafka://zlocalhost:9092)bootstrap_servers) r RuntimeErrorsuper__init__ isinstancestr kafka_urls KafkaProducerproducer KafkaConsumerr consumer)selfurlr r urls __class__s [/home/mcse/projects/flask/flask-venv/lib/python3.12/site-packages/socketio/kafka_manager.pyrzKafkaManager.__init__'s = ./ / Z@"3,u#&*,"'*Z&73qr7=MM,++dooN ++DLL>BooO ,sB.c|jj|jtj||jj y)N)value)rsendr pickledumpsflush)rdatas r_publishzKafkaManager._publish7s6 4<sA))+ 2G}} ,ll7==11 2s -A$A)zkafka://localhost:9092rF) __name__ __module__ __qualname____doc__namerr$r(r- __classcell__)rs@rrrs*, D=G!O !2r%r) loggingr r ImportErrorpubsub_managerr getLoggerloggerrr%rr:sL *   : &32=32 Es 2<<