Kafka 对中的数据库何时成为瓶颈?

When database is bottle neck in Kafka pair?

我有 Kafka 流进行中间计算,然后将其放入 mongodb。

问题是 mongodb 无法处理来自 Kafka 流的大量插入。

你是怎么解决这个问题的?

我想你会想要将中间结果写到一个主题中。然后使用 MongoDB Connector to write to MongoDB. Kafka Connect is the preferred way to write to external systems from a Kafka topic. Here's the documentation for Kafka Connect