flink 与使用 for 循环消耗 kafka 消息的 golang 程序有什么优势

【问题标题】：what are the advantages of flink vs a golang program using for loop consuming kafka messagesflink 与使用 for 循环消耗 kafka 消息的 golang 程序有什么优势
【发布时间】：2023-02-18 12:04:55
【问题描述】：

在消费kafka消息时，flink与使用for循环消费kafka消息的简单golang/java程序相比有什么优势？提前致谢~

我理解flink对exactly once assurance的支持比较好，但是还有其他的优势吗？

【问题讨论】：

标签： apache-kafka apache-flink

【解决方案1】：

忘记处理保证。 Flink 是一个 ETL 工具。它需要一个调度程序来实际部署任何作业，并且具有用于 SQL 的内置库和到外部系统的连接器。

如果您只关心用于仅 Kafka 进程的轻量级二进制文件，那么绝对可以使用 Go、Rust 等。但是您仍然需要自带调度程序（也许是 Kubernetes？）。该应用程序不会自行在 Flink/YARN 中运行...

顺便说一句，Apache Beam 有一个 Go 和 Java SDK，以及一个 Flink 运行时层，所以两者最好？

【讨论】：