Потеряет ли Kafka Stream состояние, если узел выйдет из строя и старые тематические сообщения будут удалены из-за сохранения?
По умолчанию поток kafka использует RocksDB, быстрое локальное хранилище KV, в качестве хранилища состояний. У меня такой вопрос: потеряет ли поток kafka состояние, если узел потерпит крах, и те тематические сообщения, которые будут переведены в состояние воспроизведения, будут отброшены из-за того, что произошло сохранение kafka (поэтому он не может воспроизводить сообщения с самого начала)? Значит ли это, что те старые государства потеряли в таком случае? Спасибо!
1 ответ
Kafka Streams поддерживает RocksDB store в "темах журнала изменений" в Kafka. Эти разделы журнала изменений настроены с включенным сжатием журнала. Таким образом, государство никогда не будет потеряно.