#IiP SSKrSSKrSSKJr SSKJr \R"S5r"SS\5r g!\a SrN4f=f)N)json) PubSubManagersocketiocJ^\rSrSrSrSrS U4SjjrSrSrSr Sr U=r $) 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. kafkacj>[c [S5e[TU] X#S9 [ U[ 5(aU/OUnUVs/sHnUS:waUSSOSPM snUl[R"UR S9Ul[R"URUR S9Ul gs snf)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 BooO ,sB0cURRUR[R"U5S9 URR 5 g)N)value)rsendr rdumpsflush)rdatas r_publishKafkaManager._publish7s6 4<s2))+G}} ,mm#,s ,AA)rrr)zkafka://localhost:9092rF) __name__ __module__ __qualname____firstlineno____doc__namerr&r+r0__static_attributes__ __classcell__)rs@rrrs/, D=G!O !$$r(r) loggingr ImportErrorengineiorpubsub_managerr getLoggerloggerrr(rrAsJ)   : &3$=3$ Es 4??