обработки нужно ack'нуть сообщение. Где-то в начале графа на каждое сообщение создается несколько ивентов через mapConcat. Как ack'ать сообщения после того как последний ивент который к нему относится прошел через граф?
Приходит в голову только держать мутабельную мапу в которой считать сколько прошло ивентов по каждому входящему сообещнию и ack'ать последний
Обсуждают сегодня