DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
...
Public Interfaces
New property:
| Name | Type | Default | Importance | Description |
|---|---|---|---|---|
state.cleanup.dir.max.age.ms | Long | -1 (meaning disabled) New filed for StreamsConfig: public static final long STATE_CLEANUP_DIR_MAX_AGE_MS_DISABLED = -1 | Low | Time-based threshold for purging local state directories and checkpoint files during application startup. Only state directories that have not been modified for at least state.cleanup.dir.max.age.ms will be removed |
Proposed Changes
We propose introducing a new configuration, state.cleanup.dir.max.age.ms (Long, default: -1), which defines a time-based threshold for purging local state directories and checkpoint files during application startup. When a KafkaStreams instance initializes, it compares the age of the local state against this value; if the threshold is exceeded, the local data is deleted. This forces the application to rebuild its state entirely from the changelog topic.
...