Pull requests: apache/kafka
Pull requests list
KAFKA-19926: Apply rebalance delay also for later epochs if the group is empty ci-approved group-coordinator small Small PRs
#21011 by RaidenE1 was merged Nov 28, 2025 Loading…
MINOR: update method name from Small PRs
createGroupTombstoneRecords to createGroupTombStoneRecordsAndCancelTimers ci-approved group-coordinator small #20949 by RaidenE1 was merged Nov 25, 2025 Loading…
KAFKA-19683: Final test replacements [8/N] ci-approved streams tests Test fixes (including flaky tests)
#20944 by shashankhs11 was merged Nov 26, 2025 Loading…
KAFKA-19683: Some more test replacements [7/N] ci-approved streams tests Test fixes (including flaky tests)
#20889 by shashankhs11 was merged Nov 20, 2025 Loading…
KAFKA-19683: More test replacements [6/N] ci-approved streams streams-thread-refactoring
#20858 by shashankhs11 was merged Nov 14, 2025 Loading…
KAFKA-19864: Handle TimeoutException from initializeIfNeeded() in StateUpdater Code ci-approved small Small PRs streams
#20829 by shashankhs11 was merged Nov 7, 2025 Loading…
KAFKA-19683: More test replacements [5/N] ci-approved streams tests Test fixes (including flaky tests)
#20818 by shashankhs11 was merged Nov 7, 2025 Loading…
KAFKA-19683: More cleanup and rewrite [4/N] ci-approved streams tests Test fixes (including flaky tests)
#20777 by shashankhs11 was merged Nov 3, 2025 Loading…
KAFKA-19807: Add RPC-level integration tests for StreamsGroupHeartbeat [2/2] core Kafka Broker tests Test fixes (including flaky tests)
#20762 by lucliu1108 was merged Oct 30, 2025 Loading…
KAFKA-19807: Add RPC-level integration tests for StreamsGroupHeartbeat [1/2] ci-approved core Kafka Broker tests Test fixes (including flaky tests)
#20757 by lucliu1108 was merged Oct 30, 2025 Loading…
KAFKA-19829: Implement group-level initial rebalance delay build Gradle build or GitHub Actions ci-approved clients connect consumer core Kafka Broker dependencies Pull requests that update a dependency file group-coordinator KIP-932 Queues for Kafka kraft performance producer storage Pull requests that target the storage module streams tiered-storage Related to the Tiered Storage feature tools
#20755 by RaidenE1 was merged Nov 14, 2025 Loading…
KAFKA-19521: Fix consumption and leaving group when source topic is deleted ci-approved clients consumer KIP-1071 PRs related to KIP-1071 streams
#20735 by RaidenE1 was merged Oct 22, 2025 Loading…
KAFKA-19765: Store the last used assignment configuration in the group metadata ci-approved group-coordinator KIP-1071 PRs related to KIP-1071
#20702 by lucliu1108 was merged Oct 17, 2025 Loading…
KAFKA-19683: Cleanup and rewrite more tests in TaskManagerTest [3/N] ci-approved streams tests Test fixes (including flaky tests)
#20692 by shashankhs11 was merged Oct 14, 2025 Loading…
MINOR: auto-topic creation back-off ci-approved core Kafka Broker KIP-1071 PRs related to KIP-1071
#20663 by RaidenE1 was merged Oct 10, 2025 Loading…
KAFKA-19510: clear pendingTasksToInit on tasks clear. ci-approved small Small PRs streams streams-thread-refactoring
#20646 by Nikita-Shupletsov was merged Oct 8, 2025 Loading…
KAFKA-19754: Add RPC-level integration test for StreamsGroupDescribeRequest ci-approved core Kafka Broker KIP-1071 PRs related to KIP-1071 tests Test fixes (including flaky tests)
#20632 by lucliu1108 was merged Oct 7, 2025 Loading…
MINOR: Enable streams rebalance protocol in EosIntegrationTest ci-approved KIP-1071 PRs related to KIP-1071 streams tests Test fixes (including flaky tests)
#20592 by RaidenE1 was merged Oct 5, 2025 Loading…
MINOR: Handle envelope response in AutoTopicCreationManager ci-approved core Kafka Broker KIP-1071 PRs related to KIP-1071
#20569 by RaidenE1 was merged Sep 25, 2025 Loading…
KAFKA-19683: Remove more dead tests and rewrote 3 tests in TaskManagerTest [2/N] ci-approved streams streams-thread-refactoring tests Test fixes (including flaky tests)
#20544 by shashankhs11 was merged Oct 10, 2025 Loading…
KAFKA-19705: Enable streams rebalance protocol in IQv2 integration test ci-approved KIP-1071 PRs related to KIP-1071 streams tests Test fixes (including flaky tests)
#20541 by RaidenE1 was merged Sep 18, 2025 Loading…
KAFKA-19683: Remove dead tests and modify tests in TaskManagerTest [1/N] ci-approved streams streams-thread-refactoring tests Test fixes (including flaky tests)
#20501 by shashankhs11 was merged Sep 16, 2025 Loading…
KAFKA-19666: Remove old restoration codepath from EosIntegrationTest [5/N] ci-approved small Small PRs streams streams-thread-refactoring tests Test fixes (including flaky tests)
#20499 by shashankhs11 was merged Sep 10, 2025 Loading…
KAFKA-19666: Remove old restoration codepath from RestoreIntegrationTest [4/N] ci-approved small Small PRs streams streams-thread-refactoring tests Test fixes (including flaky tests)
#20498 by shashankhs11 was merged Sep 11, 2025 Loading…
KAFKA-19666: Remove old restoration codepath from SmokeTestDriverIntegrationTest [3/N] ci-approved small Small PRs streams streams-thread-refactoring tests Test fixes (including flaky tests)
#20465 by shashankhs11 was merged Sep 8, 2025 Loading…
ProTip! Exclude everything labeled
bug with -label:bug.