【发布时间】：2015-06-29 03:14:20
【问题描述】：
我看到链接会使用kafka for MQ以便重放失败，在不同算子中传输消息时是否使用内存MQ？
【问题讨论】：
标签： apache-flink
【发布时间】：2015-06-29 03:14:20
【问题描述】：
Flink 不一定使用 Kafka 作为输入消息队列，但对它有开箱即用的支持。如果您的工作需要处理一次，建议使用此来源。
至于在 Flink 算子之间传输消息，这是一个完全不同的系统，在这个意义上与容错无关。
【讨论】：