@@ -517,20 +517,37 @@ the correct URL for a given message queue.
517517Note that Kombu currently does not support asyncio, so it cannot be used with
518518the :class: `socketio.AsyncServer ` class.
519519
520+ Kafka
521+ ~~~~~
522+
523+ `Apache Kafka <https://kafka.apache.org/ >`_ is supported through the
524+ `kafka-python <https://kafka-python.readthedocs.io/en/master/index.html >`_
525+ package::
526+
527+ pip install kafka-python
528+
529+ Access to Kafka is configured through the :class: `socketio.KafkaManager `
530+ class::
531+
532+ mgr = socketio.KafkaManager('kafka://')
533+ sio = socketio.Server(client_manager=mgr)
534+
535+ Note that Kafka currently does not support asyncio, so it cannot be used with
536+ the :class: `socketio.AsyncServer ` class.
537+
520538AioPika
521539~~~~~~~
522540
523- If you want to combine a RabbitMQ based manager with asyncio and a
524- :class: `socketio.AsyncServer ` class, you can use the
525- `AioPika <https://aio-pika.readthedocs.io/en/latest/ >`_ based manager.
541+ A RabbitMQ message queue is supported in asyncio applications through the
542+ `AioPika <https://aio-pika.readthedocs.io/en/latest/ >`_ package::
526543You need to install aio_pika with pip::
527544
528545 pip install aio_pika
529546
530547The RabbitMQ queue is configured through the
531- :class: `socketio.AsyncPubSubAioPikaManager ` ::
548+ :class: `socketio.AsyncAioPikaManager ` class ::
532549
533- mgr = socketio.AsyncPubSubAioPikaManager ('amqp://')
550+ mgr = socketio.AsyncAioPikaManager ('amqp://')
534551 sio = socketio.AsyncServer(client_manager=mgr)
535552
536553Emitting from external processes
0 commit comments