未验证 提交 75bcbcd5 编写于 作者: 片刻小哥哥's avatar 片刻小哥哥 提交者: GitHub

Merge pull request #24 from ggjj917/feature/flink_1.7_doc_zh_33

33章节修改
......@@ -11,27 +11,27 @@ Flink的容错机制在出现故障时恢复程序并继续执行它们。此类
请阅读每个连接器的文档,以了解容错保证的详细信息。
| 资源 | 担保 | 笔记 |
| 资源 | 保证 | 注意 |
| --- | --- | --- |
| Apache Kafka | 一次 | 为您的版本使用适当的Kafka连接器 |
| AWS Kinesis Streams | 一次 | |
| 的RabbitMQ | 最多一次(v 0.10)/一次(v 1.0) | |
| Twitter Streaming API | 最多一次 | |
| 集合 | 一次 | |
| | 一次 | |
| 套接字 | 最多一次 | |
| Collections | 一次 | |
| Files | 一次 | |
| Sockets | 最多一次 | |
为了保证端到端精确一次的记录传递(除了精确一次的状态语义之外),数据接收器需要参与检查点机制。下表列出了Flink与捆绑接收器的传送保证(假设一次状态更新):
| 水槽 | 担保 | 笔记 |
| 汇聚结点 | 保证 | 注意 |
| --- | --- | --- |
| HDFS滚动接收器 | 一次 | 实现取决于Hadoop版本 |
| HDFS rolling sink | 一次 | 实现取决于Hadoop版本 |
| Elasticsearch | 至少一次 | |
| Kafka制片人 | 至少一次 | |
| 卡桑德拉下沉 | 至少一次/恰好一次 | 只有幂等更新一次 |
| Kafka producer | 至少一次 | |
| Cassandra sink | 至少一次/恰好一次 | 只有幂等更新一次 |
| AWS Kinesis Streams | 至少一次 | |
| 文件汇 | 至少一次 | |
| 插座下沉 | 至少一次 | |
| 标准输出 | 至少一次 | |
| Redis下沉 | 至少一次 | |
| File sinks | 至少一次 | |
| Socket sinks | 至少一次 | |
| Standard output | 至少一次 | |
| Redis sink | 至少一次 | |
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册