This is an automated email from the ASF dual-hosted git repository.
vvcephei pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 0f96782 MINOR: guard against calls to exit in QuorumTestHarness tests
(#11457)
add 23e9818 KAFKA-13480: Track Position in KeyValue stores (#11514)
No new revisions were added by this update.
Summary of changes:
.../state/internals/InMemoryKeyValueStore.java | 22 +++++
.../kafka/streams/state/internals/Position.java | 96 ++++++++++++++++++++++
.../streams/state/internals/RocksDBStore.java | 14 ++++
.../state/internals/InMemoryKeyValueStoreTest.java | 35 ++++++++
.../MonotonicProcessorRecordContext.java} | 23 ++++--
.../streams/state/internals/PositionTest.java | 66 +++++++++++++++
.../streams/state/internals/RocksDBStoreTest.java | 37 +++++++++
7 files changed, 285 insertions(+), 8 deletions(-)
create mode 100644
streams/src/main/java/org/apache/kafka/streams/state/internals/Position.java
copy
streams/src/{main/java/org/apache/kafka/streams/state/internals/TimestampedKeyAndJoinSideSerde.java
=>
test/java/org/apache/kafka/streams/state/internals/MonotonicProcessorRecordContext.java}
(65%)
create mode 100644
streams/src/test/java/org/apache/kafka/streams/state/internals/PositionTest.java
