This is an automated email from the ASF dual-hosted git repository.
bbejeck pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from d84e19dde4f KAFKA-19712: Commit OFFSET_UNKOWN when closing state
stores and the offsets are not yet initialized (#21884)
add f55073b570f KAFKA-13499: Avoid restoring outdated records (#21901)
No new revisions were added by this update.
Summary of changes:
.../processor/internals/ProcessorStateManager.java | 22 ++++
.../processor/internals/StoreChangelogReader.java | 47 +++++++--
...stractDualSchemaRocksDBSegmentedBytesStore.java | 7 +-
.../AbstractRocksDBSegmentedBytesStore.java | 7 +-
.../state/internals/InMemorySessionStore.java | 9 +-
.../state/internals/InMemoryWindowStore.java | 7 +-
...redStateStore.java => WithRetentionPeriod.java} | 7 +-
.../internals/StoreChangelogReaderTest.java | 112 +++++++++++++++++++++
8 files changed, 200 insertions(+), 18 deletions(-)
copy
streams/src/main/java/org/apache/kafka/streams/state/internals/{MeteredStateStore.java
=> WithRetentionPeriod.java} (90%)
