Consumer у вас получает сообщение из Kafka, накапливает буфер, когда batch готов — пишет и коммитит. Что будет, если сервис упадёт в момент сборки batch?