Dynamically find kafka topics and makes available corresponding channels on a public websocket.