我想通过websocket从kafka向客户端发送消息，我有一个关于json记录的kafka主题，比如：{...fields...., type:1}。
客户端通过一条json消息启动与websocket的连接，该消息包括一个他所感兴趣的类型的数组字段，如：{...fields..., types:[1,3,4]}
我试着用Nifi做这件事，但我没有办法从卡夫卡消费，同时根据类型过滤我收到的信息。
我很乐意在Nifi或任何其他方式(流集、实现从kafka消费的成本化websocket等(中获得建议
(我的代码是用java编写的(
谢谢：(
使用Nifi，但我没有办法从kafka消费，同时通过类型过滤我得到的消息
ConsumeKafka+RecordPath筛选器应该工作良好。。。
或者，您没有提到您的Web服务器正在运行的系统类型。。。
你可以用Spring Boot写。。。或者Django。。。或者Flask+Faust或者NodeJS然后将Kafka消息从内置消费者转发到网络套接字。
tl；dr 搜索 ">您的语言+websocket+kafka"。。。我相信会有结果
或者您可以使用Kafka REST代理，然后只使用AJAX而不是WebSocket。
例如，您也可以使用Kafka Connect HTTP Sink将事件发送到打开的webhook(例如Nifi的ListenHTTP.(。