我想通过websocket从kafka向客户端发送消息，我有kafka主题，其中包含json记录，如： {...fields...., type:1} .
客户机使用json消息启动到websocket的连接，该消息包含他感兴趣的类型的数组字段，如： {...fields..., types:[1,3,4]} 我试着用nifi，但我没有一种方法来消费Kafka，同时过滤我得到的信息类型。
我很高兴能得到建议，在nifi或任何其他方式做这件事（流集，实现成本化websocket，消费Kafka等…）
（我的代码是用java编写的）
谢谢：）
1条答案
按热度按时间2sbarzqh1#
但我没有一个方法来消费Kafka，同时过滤的消息，我得到的类型
Kafka+记录路径过滤器可以正常工作。。。
或者，您没有提到您的Web服务器正在运行的系统类型。。。
你可以在Spring的 Boot 里写。。。或django。。。或者flask+faust，或者nodejs，然后将kafka消息从内置消费者转发到web套接字。
热释光；drsearch“你的语言+websocket+Kafka”。。。我肯定会有结果的
或者您可以使用kafkarest代理，然后使用ajax而不是websocket。
例如，您还可以使用kafka connect http sink将事件发送到打开的webhook（例如nifi的listenhttp）。