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
Guozhang Wang d62a42df2e
KAFKA-10199: Integrate Topology Pause/Resume with StateUpdater (#12659) 
When a topology is paused / resumed, we also need to pause / resume its corresponding tasks inside state updater.

Reviewers: Guozhang Wang <wangguoz@gmail.com>
 		2022-09-28 16:26:01 -07:00
..
examples/src MINOR: revert KIP-770 (#12383) 2022-07-07 11:19:37 -07:00
quickstart MINOR; Bump trunk to 3.4.0-SNAPSHOT (#12463) 2022-08-01 09:54:12 -07:00
src KAFKA-10199: Integrate Topology Pause/Resume with StateUpdater (#12659) 2022-09-28 16:26:01 -07:00
streams-scala MINOR: Update Scalafmt to latest version (#12475) 2022-09-12 10:05:15 -04:00
test-utils/src KAFKA-10199: Register and unregister changelog topics in state updater (#12638) 2022-09-16 09:05:11 +02: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-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
…