kafka 和 flink：获取流到 webapp

Question

我正在尝试 kafka 和 flink ：

• 我使用 flink 生产者向 kafka 发送流推文。
• 我使用几个 flink 消费者来处理这些数据（atm 只是解析，并保留来自推文的主要消息）。 现在我想在我的网络应用程序（angular2 base）中显示这些干净的消息。 这样做有什么好的做法？

如果我创建一个基本的 REST 网络服务，我想我会失去对流媒体的兴趣，对吗？

我应该为我的 webapp 提供 flink 数据还是应该将其发送到另一个 kafka 主题以将其提供给 webapp？

谢谢，

安东尼

Answer 1

我应该为我的 webapp 提供 flink 数据还是应该将其发送到另一个 kafka 主题以将其提供给 webapp？

这不会改变任何事情，您会失去对网络服务的流媒体兴趣，不是吗？ 您是否考虑过使用 websocket 引擎？为了将消息作为流发送给客户端？

取决于您的后端技术： - https://github.com/socketio/engine.io - https://docs.spring.io/spring/docs/current/spring-framework-reference/html/websocket.html#websocket-server - ...