是的，你需要使用WebSockets来进行一系列更新。Kafka在这方面没有帮助，不过，你需要找到一些解决方案来将Kafka与WebSocket客户端结合起来。

例如socket.io...

// Listen for Kafka
consumer.on('message', ({ value, }) => {
    // Parse the JSON value into an object
    const { payload, } = JSON.parse(value)

    console.log('nnemitting from kafka:', payload)

    // Emit the message through all connected sockets
    io.emit("kafka-event", payload)

请记住，上面的代码只能在一个客户端上运行。新套接字不会启动新的消费者，因此只能看到内部Kafka消费者的当前偏移量的更新。如果您启动了多个Kafka消费者(或多个Node后端)，那么您可能只会在每个套接字事件中看到Kafka分区的一个子集被消耗...

否则，这个问题对Kafka来说并不是独一无二的。您可以编写一个循环(例如setTimeout() / setInterval())来查询某个HTTP API(而不是直接查询数据库)中的所有记录和/或上次轮询后的新记录。
或者，根据您的用例，查询整个数据库表/集合+添加一些刷新按钮以准确捕获删除(除非您有一个WebSocket来发送单个删除事件，并且可以用这些事件更新DOM)。
目前有一个python-kafka使用者，监听一个流并将数据存储在postgres数据库中。

虽然这可能会奏效，但Kafka Connect的规模可能会更大。

或者，Kafka Streams支持KV queries，因此不需要外部Postgres数据库，具体取决于您的查询模式。
因此可以选择跳过数据库？

如果您不关心历史事件的保留，那么您不需要任何数据库。只有在建立了消费者套接字之后，您才能在UI中获得事件，然后丢失刷新的所有历史记录。

额外-Kafka的前端。类似的答案--你需要一个带有Kafka生产者客户端的后端服务，因为没有原生的HTTP接口。