что сообщения в output (SinkNode) флашнутся перед changelog?
А то сейчас я наблюдаю ситуацию когда у меня накопленное состояние уже в будущем, на выходе сообщений нет, а при повторной обработке берется слишком новый стейт с которого уже не получается создать тот же самый output
Можно gist с кодом? Не совсем понял вопроса
Обсуждают сегодня