为什么要在Flink中使用kafka
伊格内修斯·赖利
我目前正在发现使用flink进行流处理的领域。但是，到目前为止，我阅读的大多数专业文章都谈论flink和kafka。但是我没有找到清楚的解释，为什么这个二人组看起来如此逻辑，并解释了flink无法做到的kafka，反之亦然。
到目前为止，我发现以下内容：-flink无法使用readCsvFile进行PROCESS_CONTINUOUSLY，而kafka在这方面可以支持，-kafka可以进行流聚合，但是与kafka相比，它似乎有限（不确定）。
因此，请不要犹豫，添加您到目前为止在这些系统上拥有的知识和经验。提前非常感谢您。
ImbaBalboa
乍一看，差异确实不明显。
Apache Kafka是一种解决方案，用于处理实时信息并将其快速路由到消费者，这意味着它是消息代理。
Apache Flink是一个流处理框架。它涉及数据在内存中的分布式计算。
话虽这么说，基本上，Kafka将充当消息路由器的角色，而Apache Flink将处理数据。
如您在下面的示例模式中看到的那样，Kafka允许发布来自异构源的消息，而Apache Flink将通过应用开窗或精简功能来处理这些数据。
如果您查看Kafka文档，他们会在Kafka之上引入一个称为Kafka Stream的新功能（它不是原始Kafka的一部分）。这也是一个流处理框架，能够像Apache Flink一样处理数据。
本文收集自互联网，转载请注明来源。
如有侵权，请联系 [email protected] 删除。
编辑于
相关文章
TOP 榜单
- 1
Linux的官方Adobe Flash存储库是否已过时？
- 2
如何使用HttpClient的在使用SSL证书，无论多么“糟糕”是
- 3
错误：“ javac”未被识别为内部或外部命令，
- 4
在 Python 2.7 中。如何从文件中读取特定文本并分配给变量
- 5
Modbus Python施耐德PM5300
- 6
为什么Object.hashCode（）不遵循Java代码约定
- 7
如何检查字符串输入的格式
- 8
检查嵌套列表中的长度是否相同
- 9
错误TS2365：运算符'！=='无法应用于类型'“（”'和'“）”'
- 10
如何自动选择正确的键盘布局？-仅具有一个键盘布局
- 11
如何正确比较 scala.xml 节点？
- 12
在令牌内联程序集错误之前预期为 ')'
- 13
如何在JavaScript中获取数组的第n个元素？
- 14
如何将sklearn.naive_bayes与（多个）分类功能一起使用？
- 15
ValueError：尝试同时迭代两个列表时，解包的值太多（预期为 2）
- 16
如何监视应用程序而不是单个进程的CPU使用率？
- 17
解决类Koin的实例时出错
- 18
ES5的代理替代
- 19
有什么解决方案可以将android设备用作Cast Receiver？
- 20
VBA 自动化错误：-2147221080 (800401a8)
- 21
套接字无法检测到断开连接
我来说两句