Я видел, что ссылка будет использовать kafka для MQ, чтобы воспроизвести для отказа, и использует ли она память MQ при передаче сообщения в разных операторах?#flink различные операторы передачи сообщений использовать MQ
Флинк не обязательно использует Kafka в качестве очереди входных сообщений, но имеет поддержку для нее. Этот источник предлагается использовать в том случае, если ровно один раз обработка является требованием для вашей работы.
Что касается передачи сообщений между операторами Flink, которые являются совершенно другой системой и не связаны с отказоустойчивостью в этом смысле.