时间戳

首页 > 解决方案 > 卡夫卡消息处理

apache-kafka - 卡夫卡消息处理

问题描述

我在 Spring Boot 应用程序中使用 Kafka 分布式系统进行消息处理。现在我的应用程序正在生成关于三个不同主题的基本消息。一些数据分析团队将使用一个单独的 Spring Boot 应用程序来分析数据。此应用程序是一个简单的报表类型应用程序，只有一个过滤器主题。

现在我必须实现它，但我有点困惑如何将数据显示给 UI。我已经编写了正在消费消息的听众（消费者），但我将如何将数据实时显示给 UI。我是否需要将其存储在诸如 redis 之类的数据库中，然后将这些数据显示给 UI？这是在 Kafka 中处理消费者的正确方法吗？会不会很慢？随着时间的推移，消息会急剧增长。

简而言之，我想知道我们如何以有效的方式和实时地在任何 UI 上显示消息。

谢谢

标签： apache-kafka

解决方案

您可以编写消费者转发到 websocket。

或者您可以使用 Kafka Connect 写入数据库，然后编写 REST API

或者使用 Kafka Streams 交互式查询功能 + 在顶部添加一个 RPC 层供 Javascript 调用

推荐阅读