apache-flink - Apacheflink 的 DataStream API 如何支持事件的批处理

Question

我的生产者是 apache Kafka，我们想监听一批事件来处理它们并将处理后的事件写入数据库。如果我使用流/批处理，每个事件都会对 DB 进行一次查询。我不想将每个事件都作为一个查询来处理。如何批量处理一些事件并将这些批量数据写入数据库？

注意：我们使用的是 DataStream API

标签： apache-flinkdata-stream

Answer 1

不，Flink 没有官方的 Neo4j 接收器。如果您的目标是通过缓冲、批量事务更新来实现端到端的精确一次，您可以从阅读Apache Flink 中端到端精确一次处理的概述开始，然后联系 flink 用户邮件列表以获得进一步的指导。