kafka-ws:Kafka 包裹在 websockets 中

kafka-websocket kafka-websocket 是一个简单的 websocket 服务器接口到 kafka 分布式消息代理。 它支持客户端订阅主题，包括一次包含多个主题，以及向主题发送消息。 消息可以是文本或二进制，每种格式如下所述。 客户端可以在同一连接上生成和使用消息。 创建主题 客户端可以使用 REST 端点来创建主题。 一个例子是： /api/create?topic=my_topic 从主题消费 客户端通过在连接到 kafka-websocket 时在查询参数中指定它们来订阅主题： /v2/broker/?topics=my_topic,my_other_topic 如果没有给出主题，客户端将不会收到消息。 发送给客户端的消息格式由协商的子协议决定：kafka-text 或 kafka-binary。 如果未指定子协议，则使用 kafka-text。