Я новичок в весеннем облачном потоке и кафке в целом.
Каков наилучший подход, чтобы не дать Потребителю зафиксировать следующее смещение, если внешнее приложение не получит последнее сообщение. У меня есть промежуточное ПО, которое управляет связью между потребителем и внешним приложением. Я хочу, по крайней мере, попытаться отправить сообщение 10 раз с задержкой в 1 минуту (во внешнее приложение), если что-то пойдет не так.
Middleware - это простое приложение после запроса, которое фильтрует определенные данныев сообщении кафка.