为什么要在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] 删除。
编辑于
相关文章
Related 相关文章
- 1
为什么要在Android中使用RequestQueue？
- 2
为什么我要在Dockerfile中使用VOLUME？
- 3
为什么要在JavaScript变量的名称中使用$（美元符号）？
- 4
为什么要在Java中使用`transient`关键字？
- 5
为什么要在main方法中使用SwingUtilities.invokeLater？
- 6
为什么要在golang中使用组合？
- 7
为什么要在Spring中使用self类？
- 8
为什么要在“ if”语句中使用语句？
- 9
为什么要在Git中使用core.autocrlf = true？
- 10
为什么要在FRP中使用行为
- 11
为什么要在Flux中使用“动作”？
- 12
为什么要在Java卡程序中使用“ setSeed（）”？
- 13
为什么要在laravel中使用npm？
- 14
为什么要在Dropwizard指标中使用CachedGauage？
- 15
为什么要在该程序中使用fflush（stdin）？
- 16
为什么要在DI中使用`deps`属性
- 17
为什么要在实时处理中使用Apache Kafka
- 18
为什么要在AngularJS中使用$ onInit？
- 19
为什么要在Dialogflow中使用动作
- 20
为什么要在Typescript中使用接口
- 21
为什么要在python中使用`iter`函数
- 22
蜂巢：为什么要在选择中使用分区？
- 23
为什么要在延迟中使用setTimeout
- 24
为什么要在结构中使用malloc？
- 25
为什么要在Python中使用导入BaseHTTPServer？
- 26
为什么要在ListView中使用DataTemplate？
- 27
为什么要在执行脚本中使用bash？
- 28
什么是背景？为什么要在odoo中使用？
- 29
为什么要在 Angular 中使用 ValueAccessor？
我来说两句