gabriellafu d3378689fe KAFKA-21297 Refactor maybeUpdateLimitOffsetsForStandbyChangelogs (#23966) ...

Replace the for-loop with anyMatch in
maybeUpdateLimitOffsetsForStandbyChangelogs. Both short-circuit on the
first partition with buffered records, so there is no behavior change.

Reviewers: Chia-Ping Tsai <chia7712@gmail.com>

2026-10-28 01:18:33 +08:00

..

examples/src

KAFKA-20956 Remove hamcrest from org.apache.kafka.streams.examples package (#23192)

2026-08-21 02:06:11 +08:00

integration-tests/src/test

KAFKA-21230: Pause processing on uncommitted bytes (#23728)

2026-10-27 12:15:08 -04:00

quickstart

MINOR: Bump trunk to 4.5.0-SNAPSHOT (#23125)

2026-08-13 17:23:17 +01:00

src

KAFKA-21297 Refactor maybeUpdateLimitOffsetsForStandbyChangelogs (#23966)

2026-10-28 01:18:33 +08:00

streams-scala

KAFKA-20553 Remove Scala dependency from streams:integration-tests (#22675)

2026-06-26 03:14:43 +08:00

test-utils/src

MINOR: Replace try/fail/catch with assertThrows in remaining Streams tests (#23636)

2026-10-15 15:43:33 +08:00

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

MINOR: Add 4.0.0 to streams system tests (#19239)

2025-03-21 01:41:09 -07:00

upgrade-system-tests-39/src/test/java/org/apache/kafka/streams/tests

MINOR: Add 4.0.0 to streams system tests (#19239)

2025-03-21 01:41:09 -07:00

upgrade-system-tests-40/src/test/java/org/apache/kafka/streams/tests

MINOR: Add 4.0.0 to streams system tests (#19239)

2025-03-21 01:41:09 -07:00

upgrade-system-tests-41/src/test/java/org/apache/kafka/streams/tests

MINOR: Add 4.1.0 to streams system tests (#20480)

2025-09-10 16:23:55 +02:00

upgrade-system-tests-42/src/test/java/org/apache/kafka/streams/tests

MINOR: Add 4.2.0 and 4.3.0 to streams system tests (#22383)

2026-05-28 19:24:48 +02:00

upgrade-system-tests-43/src/test/java/org/apache/kafka/streams/tests

MINOR: Add 4.2.0 and 4.3.0 to streams system tests (#22383)

2026-05-28 19:24:48 +02: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

KAFKA-4848: Fix retryWithBackoff deadlock issue

2017-03-20 21:56:15 -07:00