В транзакциях alpakka мы можем получать сообщения только один раз. Таким образом, фиксация выполняется только тогда, когда сообщения используются и обрабатываются.
- Но если произошла ошибка, мы перезапускаем поток каждый раз?
- Что, если одно и то же сообщение продолжает выдавать ошибку каждый раз? Это будет go в мертвом l oop.
Кажется, у Spring есть способ сделать это https://docs.spring.io/spring-kafka/reference/html/#seek до текущего
Однако, как изящно остановится поток?