1

我看到链接将使用kafka for MQ以便重播失败，并且在不同运营商中传输消息时是否使用内存MQ？

4

1 回答 1

1

Flink 不一定使用 Kafka 作为输入消息队列，但对它有开箱即用的支持。如果您的工作需要处理一次，建议使用此来源。

至于在 Flink 算子之间传输消息，这是一个完全不同的系统，在这个意义上与容错无关。

于 2015-06-29T12:17:03.760 回答