root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 4 Packages Projects Releases Wiki Activity
kafka/streams
History
Victoria Xia 84351efd51
KAFKA-14491: [13/N] Add versioned store builder and materializer (#13274) 
This PR introduces VersionedKeyValueStoreBuilder for building the new versioned stores introduced in KIP-889, analogous to the existing TimestampedKeyValueStoreBuilder for building timestamped stores. This PR also updates the existing KTable store materializer class to materialize versioned stores in addition to timestamped stores. As part of this change, the materializer is renamed from TimestampedKeyValueStoreMaterializer to simply KeyValueStoreMaterializer.

Reviewers: Matthias J. Sax <matthias@confluent.io>, John Roesler <john@confluent.io>
 		2023-03-06 17:13:33 -08:00
..
examples/src MINOR Fix checkstyle failures in streams/examples module. (#13055) 2022-12-29 16:29:18 +05:30
quickstart MINOR: bump streams quickstart pom versions and add to list in gradle.properties (#13064) 2023-01-09 15:51:44 -08:00
src KAFKA-14491: [13/N] Add versioned store builder and materializer (#13274) 2023-03-06 17:13:33 -08:00
streams-scala chore: Fix scaladoc warnings (#13164) 2023-01-31 09:00:48 -08:00
test-utils/src MINOR: Simplify JUnit assertions in tests; remove accidental unnecessary code in tests (#13219) 2023-02-16 16:13:31 +01:00
upgrade-system-tests-10/src/test/java/org/apache/kafka/streams/tests KAFKA-12499: add transaction timeout verification (#10482) 2021-05-21 15:05:39 -07:00
upgrade-system-tests-11/src/test/java/org/apache/kafka/streams/tests KAFKA-12499: add transaction timeout verification (#10482) 2021-05-21 15:05:39 -07:00
upgrade-system-tests-20/src/test/java/org/apache/kafka/streams/tests KAFKA-12499: add transaction timeout verification (#10482) 2021-05-21 15:05:39 -07:00
upgrade-system-tests-21/src/test/java/org/apache/kafka/streams/tests KAFKA-12499: add transaction timeout verification (#10482) 2021-05-21 15:05:39 -07:00
upgrade-system-tests-22/src/test/java/org/apache/kafka/streams/tests KAFKA-12499: add transaction timeout verification (#10482) 2021-05-21 15:05:39 -07:00
upgrade-system-tests-23/src/test/java/org/apache/kafka/streams/tests KAFKA-12499: add transaction timeout verification (#10482) 2021-05-21 15:05:39 -07:00
upgrade-system-tests-24/src/test/java/org/apache/kafka/streams/tests MINOR: Add upgrade tests for FK joins (#12122) 2022-05-13 17:21:27 -07:00
upgrade-system-tests-25/src/test/java/org/apache/kafka/streams/tests MINOR: Add upgrade tests for FK joins (#12122) 2022-05-13 17:21:27 -07:00
upgrade-system-tests-26/src/test/java/org/apache/kafka/streams/tests MINOR: Add upgrade tests for FK joins (#12122) 2022-05-13 17:21:27 -07:00
upgrade-system-tests-27/src/test/java/org/apache/kafka/streams/tests MINOR: Add upgrade tests for FK joins (#12122) 2022-05-13 17:21:27 -07:00
upgrade-system-tests-28/src/test/java/org/apache/kafka/streams/tests MINOR: Add upgrade tests for FK joins (#12122) 2022-05-13 17:21:27 -07:00
upgrade-system-tests-30/src/test/java/org/apache/kafka/streams/tests MINOR: Add upgrade tests for FK joins (#12122) 2022-05-13 17:21:27 -07:00
upgrade-system-tests-31/src/test/java/org/apache/kafka/streams/tests MINOR: Add upgrade tests for FK joins (#12122) 2022-05-13 17:21:27 -07:00
upgrade-system-tests-32/src/test/java/org/apache/kafka/streams/tests KAFKA-13930: Add 3.2.0 Streams upgrade system tests (#12209) 2022-06-21 16:33:40 +02:00
upgrade-system-tests-33/src/test/java/org/apache/kafka/streams/tests KAFKA-14279: Add 3.3.x streams system tests (#13077) 2023-01-09 23:37:05 -08:00
upgrade-system-tests-0100/src/test/java/org/apache/kafka/streams/tests KAFKA-12499: add transaction timeout verification (#10482) 2021-05-21 15:05:39 -07:00
upgrade-system-tests-0101/src/test/java/org/apache/kafka/streams/tests KAFKA-12499: add transaction timeout verification (#10482) 2021-05-21 15:05:39 -07:00
upgrade-system-tests-0102/src/test/java/org/apache/kafka/streams/tests KAFKA-12499: add transaction timeout verification (#10482) 2021-05-21 15:05:39 -07:00
upgrade-system-tests-0110/src/test/java/org/apache/kafka/streams/tests KAFKA-12499: add transaction timeout verification (#10482) 2021-05-21 15:05:39 -07:00
.gitignore
…