Websocket server interface for Kafka distributed message broker