Kafka streams - отключить чтение состояния из журнала изменений

Question

Я создал приложение, используя Kafka Streams, и выполнил некоторые агрегации по моей теме ввода.

Прямо сейчас, когда приложение запускается, ему требуется несколько минут, чтобы воспроизвести его состояние из журнала изменений kafka.(состояние dir не сохраняется между запусками).

Я хотел бы отключить чтение из журнала изменений при запуске, то есть оно будет начинаться с нуля.Возможно ли это?

Answer 1

Вы можете отключить регистрацию изменений через Materialized#withLoggingDisabled().

Все операторы с состоянием (например, aggregate(), join()) принимают необязательный параметр Materialized.