我有进行中间计算的Kafka流,然后将其放入mongodb。
问题是mongodb无法处理来自Kafka流的大量插入。
您如何解决此问题?
我想您将把中间结果写到一个主题上。然后使用MongoDB Connector写入MongoDB。 Kafka Connect是从Kafka主题写入外部系统的首选方式。这是Kafka Connect