【文件属性】：
文件名称：kafka-ws:Kafka 包裹在 websockets 中
文件大小：30KB
文件格式：ZIP
更新时间：2021-06-14 14:23:05
Java
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。
【文件预览】：
kafka-ws-master
----src()
--------main()
----config()
--------consumer.properties(770B)
--------producer.properties(666B)
--------server.properties(694B)
----LICENSE(11KB)
----README.md(2KB)
----pom.xml(7KB)
----.gitignore(714B)
----test.html(2KB)