или kafka streams? Кажется, что очень удобно было бы делать снапшоты состояния операторов, если каждый оператор это процесс, то просто State можно сеарелизовать на диск.
возможно мимо но все таки https://www.rabbitmq.com/streams.html
Это не совсем то. Речь идёт о потоковой обработке данных. И пока мы делаем тупой map, то все хорошо, но на нём далеко не уедешь. А если хочется усреднить события по времени, или сделать join двух потоков, то необходимо хранить состояние оператора на случай падения и перезапуска.
оператор это что?
Оператор это тот код, который преобразует один поток (потоки) сообщений в другой поток сообщений.
Удобно сказать, осталось замерять сколько по времени будет занимать снэпшот состояния после каждого получения сообщения.
А зачем делать снэпшоты? Kafka streams что делает снэпшоты?
Обсуждают сегодня