Skip to content

Pull requests: apache/kafka

New pull request New
440 Open 22,203 Closed
440 Open 22,203 Closed
Author
Filter by author
Loading
Label
Filter by label
Loading
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Loading
Milestones
Filter by milestone
Loading
Reviews
Filter by reviews
No reviews Review required Approved review Changes requested
Assignee
Filter by who’s assigned
Assigned to nobody Loading
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

MINOR: Update docker_scan supported_image_tag for 4.3.1 build Gradle build or GitHub Actions small Small PRs
#22657 opened Jun 23, 2026 by bbejeck Member Loading…
Sync 2 recent commits to 4.3
#22656 opened Jun 23, 2026 by dongnuo123 Contributor Loading…
Sync 2 recent commits to 4.2
#22655 opened Jun 23, 2026 by dongnuo123 Contributor Loading…
KAFKA-20579: Initial producer incremental allocation for uncompressed data build Gradle build or GitHub Actions clients core Kafka Broker producer tools
#22654 opened Jun 23, 2026 by lianetm Member Loading…
KAFKA-20498: Add isolation-level reads to RocksDBStore streams triage PRs from the community
#22653 opened Jun 23, 2026 by nicktelford Contributor Loading…
1
KAFKA-20495: Add transactional support to in-memory window and session stores streams triage PRs from the community
#22652 opened Jun 23, 2026 by nicktelford Contributor Loading…
1
KAFKA-20733: Fix fetchResponseWithUnexpectedPartitionIsIgnored passing for wrong reason with CONSUMER protocol ci-approved clients consumer small Small PRs tests Test fixes (including flaky tests)
#22651 opened Jun 23, 2026 by david-parkk Contributor Loading…
3
MINOR: Merge kafka.security classes into test-common build Gradle build or GitHub Actions clients core Kafka Broker tools
#22650 opened Jun 23, 2026 by mimaison Member Loading…
KAFKA-20724: prevent duplicate task in tasks() during pause and resume small Small PRs streams triage PRs from the community
#22649 opened Jun 23, 2026 by zoro30102000 Loading…
KAFKA-20490: Replace txn buffer skip-list with TreeMap streams triage PRs from the community
#22648 opened Jun 23, 2026 by nicktelford Contributor Loading…
1
KAFKA-20686: Add base integ tests for share group DLQ. [1/N] ci-approved clients KIP-932 Queues for Kafka tests Test fixes (including flaky tests) triage PRs from the community
#22647 opened Jun 23, 2026 by smjn Collaborator Loading…
3
KAFKA-20116: Send task-(end)-offset only if changed (5/N) clients consumer group-coordinator kip Requires or implements a KIP streams
#22645 opened Jun 23, 2026 by mjsax Member Loading…
@lucasbru
4
KAFKA-20116: Forwad task-(end)-offset to task assignor (4/N) group-coordinator kip Requires or implements a KIP streams
#22644 opened Jun 23, 2026 by mjsax Member Loading…
KAFKA-20727: Update system tests for transactional state stores small Small PRs tests Test fixes (including flaky tests)
#22642 opened Jun 22, 2026 by bbejeck Member Loading…
2
MINOR: reduce allocations constructing RecordHeaders ci-approved clients small Small PRs triage PRs from the community
#22641 opened Jun 22, 2026 by winfriedgerlach Loading…
1
KAFKA-20625: Add StreamsGroupTopologyDescriptionRequestManager and Streams client topology push [2/N] ci-approved clients consumer streams triage PRs from the community
#22640 opened Jun 22, 2026 by lucliu1108 Contributor Loading…
@lucasbru
11
MINOR: Move DelayedProduceTest to server module core Kafka Broker tests Test fixes (including flaky tests) triage PRs from the community
#22638 opened Jun 22, 2026 by m1a2st Collaborator Loading…
3
MINOR: Fix raw type warnings in AbstractHeartbeatRequestManagerTest ci-approved clients consumer small Small PRs tests Test fixes (including flaky tests) triage PRs from the community
#22637 opened Jun 22, 2026 by cychiu8 Contributor Loading…
1
KAFKA-20723: Add fail fast check for share group dlq(...). [1/N] ci-approved core Kafka Broker KIP-932 Queues for Kafka small Small PRs
#22635 opened Jun 22, 2026 by smjn Collaborator Loading…
5
MINOR: optimize cooperative assignment validation clients consumer small Small PRs triage PRs from the community
#22633 opened Jun 21, 2026 by coderbruis Loading…
KAFKA-20718: Fix flaky test OffsetStorageReaderTest.testClosingOffsetReaderWhenOffsetStoreHangsAndHasIncompleteFutures ci-approved connect small Small PRs tests Test fixes (including flaky tests) triage PRs from the community
#22632 opened Jun 21, 2026 by majialoong Contributor Loading…
KAFKA-20700: Resolve symlinks in AllowedPaths before validation clients small Small PRs triage PRs from the community
#22631 opened Jun 20, 2026 by nileshkumar3 Contributor Loading…
MINOR: Test Producer's and Accumulator's Behavior When Batch Size is Zero clients producer small Small PRs tests Test fixes (including flaky tests) triage PRs from the community
#22628 opened Jun 19, 2026 by jack2012aa Contributor Loading…
KAFKA-20696: Periodic plugin.deleteTopology cleanup for naturally-expired streams groups group-coordinator
#22622 opened Jun 19, 2026 by frankvicky Contributor Loading…
@lucasbru
18
KAFKA-19092: Fix flaky testBalancePartitionLeaders by reducing check interval and increasing timeout kraft small Small PRs tests Test fixes (including flaky tests) triage PRs from the community
#22621 opened Jun 19, 2026 by suryakantade Loading…
ProTip! Add no:assignee to see everything that’s not assigned.