Skip to content

Pull requests: apache/kafka

New pull request New
428 Open 22,226 Closed
428 Open 22,226 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

KAFKA-20730: Remove scalafmt from streams-scala Spotless config build Gradle build or GitHub Actions ci-approved small Small PRs triage PRs from the community
#22668 opened Jun 24, 2026 by JiayaoS Contributor Loading…
KAFKA-19738: Add unit tests for OffsetsRequestManager ListOffsets request building clients consumer tests Test fixes (including flaky tests) triage PRs from the community
#22667 opened Jun 24, 2026 by peterzdhuang Loading…
KAFKA-20703: IQv2 TimestampedKeyWithHeadersQuery for headers-aware key-value stores (KIP-1356) streams triage PRs from the community
#22666 opened Jun 24, 2026 by Jess668 Contributor • Draft
KFK-19871: A, Add Builder and Runtime for Multipartition for TopologyTestDriver streams triage PRs from the community
#22665 opened Jun 24, 2026 by sebastienviale Contributor Loading…
KAFKA-20717: Add broker-side set/get observability sensors for streams topology description (KIP-1331) ci-approved group-coordinator triage PRs from the community
#22664 opened Jun 24, 2026 by aliehsaeedii Contributor Loading…
@frankvicky
10
KAFKA-20570: Catch RuntimeException in ConsumerProtocol deserialization in group coordinator
#22663 opened Jun 24, 2026 by dongnuo123 Contributor Loading…
KAFKA-20732: seed highestOffsetInRemoteStorage before size-based remote retention small Small PRs storage Pull requests that target the storage module tiered-storage Related to the Tiered Storage feature triage PRs from the community
#22661 opened Jun 24, 2026 by horkyada Loading…
MINOR: Code cleanups in coordinator-common runtime group-coordinator small Small PRs triage PRs from the community
#22660 opened Jun 24, 2026 by sjhajharia Collaborator Loading…
1
KAFKA-60665: Add refiner scaffolding for "streams" warmup tasks group-coordinator kip Requires or implements a KIP streams
#22658 opened Jun 24, 2026 by mjsax Member Loading…
KAFKA-20579: Initial producer incremental allocation for uncompressed data build Gradle build or GitHub Actions ci-approved 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…
2
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…
8
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-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
5
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…
2
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
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…
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-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…
KAFKA-20661; Implement checking for voter default endpoint ci-approved kraft
#22620 opened Jun 18, 2026 by jsancio Member Loading…
23
KAFKA-19880: fix(storage): reject non-zero sequence on first batch with no producer state storage Pull requests that target the storage module triage PRs from the community
#22619 opened Jun 18, 2026 by wilmerdooley Loading…
ProTip! Filter pull requests by the default branch with base:trunk.