предусмотрев решение дедупликации, вторая задача решена автоматически - разве нет?

прерванное выполнение обработки с изменением внешнего стейта?

Ну я так понял, что Кирилла беспокоил грейсфул с упоминанием дедупликации т.к. есть некоторый стейт дедупликации, который не должен персиститься на каждое сообщение.
Притом, чтобы восстановить этот стейт нужно прочитать больше сообщений, чем те, что уже отражены в основном стейте

Получается, что либо нужно два разных сорта офсета либо, гарантировать, что при шатдауне помимо комита офсета запишется доп стейт дедупликации

Изначально мой вопрос был про повторную обработку события, изменяющего стейт (и, возможно, не один). Таким образом, если обработка события влечет за собой изменение нескольких стейтов (например, апдейт нескольких таблиц), то не-грейсфул шатдаун посередине обработки события приведет к тому, что какие-то стейты будут обновлены, а какие-то нет, и повторная обработка события повлечет за собой повторное изменение стейтов, которые уже были изменены.

либо при этих ваших "дедупликациях" - не будут изменены стейты которые не успели обновититься из за шатдауна

Думаю, принципиально этот кейс неразрешим, т.к. грейсфул шатдаун гарантировать невозможно.
Насколько я понимаю, вместо этого предполагается использовать дополнительную обработку сообшений.
Т.е. из топика перекладывать, агрегируя и насыщая, в специализированные топики для отдельных стейтов

непонятно. т.е. есть желание обработать грейсфул, но не хочется обрабатывать жесткое выключение?

по-моему нужно стейт делать с учетом этой фигни, а не надеяться на транспорт

Всем привет
Кто-то писал скрипты для gatling?

Очень нужна помощь

На первый-второй рассчитась :)

Выполняю обращение к методу api
Запрос - post
Вопрос, как в цикле в .body подставить все json файлы из некоторой директории?

В гугле к сожалению так и не смог найти внятный пример

Мой код:
var fileHere = (new java.io.File("/LoadTest/Templates/JSON")).listFiles()
     for ( i <- 0 to fileHere.length - 1)
...
.exec(http("send document").post("/api/document")
                           .header("Token","${Token}")                            
                           .body(RawFileBody(fileHere(i).getPath())).asJson
                           .check(status is 200)
       )

Там где ... получаю токен, там ничего интересного и все работает

Копай в сторону multipart form request

Посмотрю, спасибо!

можно задам тупой вопрос
если поставить -Xfatal-warnings
то может ли быть ситуация когда из-за этого будет валиться компиляция (например standalone/одномодульного sbt проекта) из-за зависимости на какую-то уже скомпиленую библиотеку?

deprecated разве что