Kafka Streams - синхронизация коммитов с удалением БД Rocks

Question

В низкоуровневом API процессора я хотел удалить ключ из хранилища сразу после того, как соответствующее значение было переадресовано в нисходящий поток. В случае перебалансировки ИЛИ ошибки при фиксации, будет ли удаление, выполненное при откате хранилища, самостоятельно ИЛИ навсегда удалено? Если позже, есть ли способ синхронизации хранилища удалить против фиксации. Будет ли описанное выше поведение отличаться при включенном кеше в магазине и не включенном?

Answer 1

Поведение не зависит от кэширования, и если вы запускаете с гарантией «хотя бы раз», магазин не откатится.

Если вам нужны более строгие гарантии, вы можете включить обработку «точно один раз», которая обеспечит синхронизацию с запрошенным вами магазином.