How to use Kafka Cluster in flask-socketio

[boomjuice]

I have a kafka cluster config like this .
message_queue: kafka://10.0.42.149:9092,10.0.42.154:9092,10.0.42.156:9092

so I pass the config to socketio, it raises error because the bootstrap_servers is invalid.

I get one solution that passing 'client_manager' by myself

Is there have any other solution?

[boomjuice]

🧐 I find a method to solve it but i am not sure it makes sense

[miguelgrinberg]

Flask-SocketIO does not currently support a cluster of URLs, so my recommendation is that you create your client manager instance. The comma-separated IP address is not a standard URL format, so while you are free to use that format in your own application I will not be implementing something like that here.