у меня что-то упало, сделаю ретрай(в крайнем случае, кину в другой топик), если все норм, кину ack и не будет повторных сообщений. В чем я не права?
если ты упал - пойдешь вычитывать и обрабатывать заново, а если у тебя именно ack упал?
Если упал ack значит не закоммитилось, нужно снова кидать ack
Я тут немного подумала, и если ack упадет, а сообщение отправят другому консьюмеру, то exactly-once сохранится, так как первый консьюмер просто все откатит, если нет, конечно, взаимодействия с внешней системой. И если в теории exactly-once невозможен, то почему confluence пишет, что у них он есть? https://www.confluent.io/blog/exactly-once-semantics-are-possible-heres-how-apache-kafka-does-it/
Как первый консьюмер все откатит, если выполнение кода из приложения ушло во фреймворк? В листенере к примеру
Обсуждают сегодня