You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
{{ message }}
This repository was archived by the owner on Aug 19, 2025. It is now read-only.
In broadcaster._backends.kafka we are preparing bootstrap server by passing list of entire netloc string as shown below: https://github.com/encode/broadcaster/blob/master/broadcaster/_backends/kafka.py#L13 self._servers = [urlparse(url).netloc]
If we tweak above line with below statement then it will support kafka cluster connection string: self._servers = urlparse(url).netloc.split(',')