You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by vv...@apache.org on 2021/11/25 00:29:51 UTC

[kafka] branch trunk updated (0f96782 -> 23e9818)

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