root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity
kafka/streams
History
A. Sophie Blee-Goldman 09e8fa2dbe
KAFKA-18026: KIP-1112, migrate stream-table joins to use ProcesserSupplier#stores (#18047) 
Covers wrapping of processors and state stores for KStream-KTable joins

Reviewers: Almog Gavra <almog@responsive.dev>, Guozhang Wang <guozhang.wang.us@gmail.com>
 		2024-12-05 10:06:11 -08:00
..
examples/src KAFKA-18050 Upgrade the checkstyle version to 10.20.2 (#17999) 2024-12-05 10:59:18 +08:00
integration-tests/src/test KAFKA-18050 Upgrade the checkstyle version to 10.20.2 (#17999) 2024-12-05 10:59:18 +08:00
quickstart Bump trunk to 4.0.0-SNAPSHOT 2024-07-29 15:51:54 -07:00
src KAFKA-18026: KIP-1112, migrate stream-table joins to use ProcesserSupplier#stores (#18047) 2024-12-05 10:06:11 -08:00
streams-scala KAFKA-17893: Support record keys in the foreignKeyExtractor argument of KTable foreign join (#17756) 2024-12-03 17:34:13 +01:00
test-utils/src KAFKA-18013: Add AutoOffsetResetStrategy internal class (#17858) 2024-11-25 19:11:12 +05:30
upgrade-system-tests-10/src/test/java/org/apache/kafka/streams/tests MINOR: Code cleanup Kafka Streams (#16050) 2024-10-23 16:54:06 -07:00
upgrade-system-tests-11/src/test/java/org/apache/kafka/streams/tests MINOR: Code cleanup Kafka Streams (#16050) 2024-10-23 16:54:06 -07:00
upgrade-system-tests-20/src/test/java/org/apache/kafka/streams/tests MINOR: Code cleanup Kafka Streams (#16050) 2024-10-23 16:54:06 -07:00
upgrade-system-tests-21/src/test/java/org/apache/kafka/streams/tests MINOR: Code cleanup Kafka Streams (#16050) 2024-10-23 16:54:06 -07:00
upgrade-system-tests-22/src/test/java/org/apache/kafka/streams/tests MINOR: Code cleanup Kafka Streams (#16050) 2024-10-23 16:54:06 -07:00
upgrade-system-tests-23/src/test/java/org/apache/kafka/streams/tests MINOR: Code cleanup Kafka Streams (#16050) 2024-10-23 16:54:06 -07:00
upgrade-system-tests-24/src/test/java/org/apache/kafka/streams/tests KAFKA-17759 Remove Utils.mkSet (#17460) 2024-10-11 21:20:43 +08:00
upgrade-system-tests-25/src/test/java/org/apache/kafka/streams/tests KAFKA-17759 Remove Utils.mkSet (#17460) 2024-10-11 21:20:43 +08:00
upgrade-system-tests-26/src/test/java/org/apache/kafka/streams/tests KAFKA-17759 Remove Utils.mkSet (#17460) 2024-10-11 21:20:43 +08:00
upgrade-system-tests-27/src/test/java/org/apache/kafka/streams/tests KAFKA-17759 Remove Utils.mkSet (#17460) 2024-10-11 21:20:43 +08:00
upgrade-system-tests-28/src/test/java/org/apache/kafka/streams/tests KAFKA-17759 Remove Utils.mkSet (#17460) 2024-10-11 21:20:43 +08:00
upgrade-system-tests-30/src/test/java/org/apache/kafka/streams/tests KAFKA-17759 Remove Utils.mkSet (#17460) 2024-10-11 21:20:43 +08:00
upgrade-system-tests-31/src/test/java/org/apache/kafka/streams/tests KAFKA-17759 Remove Utils.mkSet (#17460) 2024-10-11 21:20:43 +08:00
upgrade-system-tests-32/src/test/java/org/apache/kafka/streams/tests KAFKA-17759 Remove Utils.mkSet (#17460) 2024-10-11 21:20:43 +08:00
upgrade-system-tests-33/src/test/java/org/apache/kafka/streams/tests KAFKA-17759 Remove Utils.mkSet (#17460) 2024-10-11 21:20:43 +08:00
upgrade-system-tests-34/src/test/java/org/apache/kafka/streams/tests KAFKA-17759 Remove Utils.mkSet (#17460) 2024-10-11 21:20:43 +08:00
upgrade-system-tests-35/src/test/java/org/apache/kafka/streams/tests KAFKA-17759 Remove Utils.mkSet (#17460) 2024-10-11 21:20:43 +08:00
upgrade-system-tests-36/src/test/java/org/apache/kafka/streams/tests KAFKA-17759 Remove Utils.mkSet (#17460) 2024-10-11 21:20:43 +08:00
upgrade-system-tests-37/src/test/java/org/apache/kafka/streams/tests KAFKA-17759 Remove Utils.mkSet (#17460) 2024-10-11 21:20:43 +08:00
upgrade-system-tests-38/src/test/java/org/apache/kafka/streams/tests KAFKA-17759 Remove Utils.mkSet (#17460) 2024-10-11 21:20:43 +08:00
upgrade-system-tests-39/src/test/java/org/apache/kafka/streams/tests KAFKA-18006: Add 3.9.0 to end-to-end test (streams) (#17800) 2024-11-15 14:58:24 +01:00
upgrade-system-tests-0100/src/test/java/org/apache/kafka/streams/tests MINOR: Code cleanup Kafka Streams (#16050) 2024-10-23 16:54:06 -07:00
upgrade-system-tests-0101/src/test/java/org/apache/kafka/streams/tests MINOR: Code cleanup Kafka Streams (#16050) 2024-10-23 16:54:06 -07:00
upgrade-system-tests-0102/src/test/java/org/apache/kafka/streams/tests MINOR: Code cleanup Kafka Streams (#16050) 2024-10-23 16:54:06 -07:00
upgrade-system-tests-0110/src/test/java/org/apache/kafka/streams/tests MINOR: Code cleanup Kafka Streams (#16050) 2024-10-23 16:54:06 -07:00
.gitignore
…