i* xSSKrSSKrSSKJr \R "S5r"SS\5rg!\a SrN.f=f)N) PubSubManagersocketiocJ^\rSrSrSrSrS U4SjjrSrSrSr Sr U=r $) KafkaManager aKafka 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. A write-only instance can be used independently of the server to emit to clients from an external process. :param logger: a custom logger to log it. If not given, the server logger is used. :param json: An alternative JSON module to use for encoding and decoding packets. Custom json modules must have ``dumps`` and ``loads`` functions that are compatible with the standard library versions. This setting is only used when ``write_only`` is set to ``True``. Otherwise the JSON module configured in the server is used. kafkacn>[c [S5e[TU] X#UUS9 [ 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_onlyloggerjsonzkafka://zlocalhost:9092)bootstrap_servers) r RuntimeErrorsuper__init__ isinstancestr kafka_urls KafkaProducerproducer KafkaConsumerr consumer)selfurlr r r rurls __class__s S/home/admin/cozy_coffee/venv/lib/python3.13/site-packages/socketio/kafka_manager.pyrKafkaManager.__init__0s = ./ / "  $#3,,u#&*,&*s'*Z&73qr7=MM&*,++dooN ++DLL>BooO ,sB2cURRURURR U5S9 URR 5 g)N)value)rsendr rdumpsflush)rdatas r_publishKafkaManager._publishAs: 4<r@sG*   : &>$=>$ Es .99