У меня есть облачный поток kafka с реактивным приложением, которое потребляет сообщения в пакетном режиме, используя время ожидания буфера реактора для сбора n сообщений и некоторой обработки. Я также включил ручную фиксацию для подтверждения каждого сообщения только после того, как все n сообщений были обработаны .Если обработка не удалась, все n сообщений не будут зафиксированы.
- Есть ли способ не получать больше сообщений во время обработки текущего пакета?
- Разрешает ли ручная фиксация получать дополнительные записи только после подтверждения текущего пакета?
- Имеют ли потребительские паузы и возобновления влияния в этом сценарии?
- Смогу ли я возобновить работу потребителя и повторить тот же пакет без перезапуска приложения на основании проверки работоспособности?