Skip to content

Pull requests: apache/kafka

New pull request New
435 Open 22,172 Closed
435 Open 22,172 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-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…
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…
KAFKA-19867: fix(raft): avoid UpdateVoteRequest from broker-only nodes kraft small Small PRs triage PRs from the community
#22618 opened Jun 18, 2026 by wilmerdooley Loading…
KAFKA-20713: Lower level for client log on self-healing session not found clients small Small PRs
#22617 opened Jun 18, 2026 by lianetm Member Loading…
2
KAFKA-20712: Fix transaction state name in log decoder output small Small PRs tools triage PRs from the community
#22615 opened Jun 18, 2026 by fvaleri Contributor Loading…
2
KAFKA-20711: Measure restore progress in offset slots streams triage PRs from the community
#22614 opened Jun 18, 2026 by nicktelford Contributor Loading…
MINOR: Fix assertion and grammar issues in KafkaConsumerTest ci-approved clients consumer small Small PRs tests Test fixes (including flaky tests) triage PRs from the community
#22613 opened Jun 18, 2026 by david-parkk Contributor Loading…
Add partition support to TestRecord streams tests Test fixes (including flaky tests)
#22612 opened Jun 18, 2026 by sebastienviale Contributor Loading…
15
KAFKA-19794: fix(mirror): avoid rewinding active consumer offsets in MirrorCheckpointTask connect mirror-maker-2 triage PRs from the community
#22610 opened Jun 18, 2026 by wilmerdooley Loading…
1 of 5 tasks
KAFKA-19717: fix(connect/transforms): preserve fractional digits in InsertHeader literal values connect small Small PRs triage PRs from the community
#22609 opened Jun 18, 2026 by wilmerdooley Loading…
KAFKA-20116: Make task-end-offset-sum available to client background thread (2/N) clients consumer core Kafka Broker kip Requires or implements a KIP streams
#22608 opened Jun 17, 2026 by mjsax Member Loading…
6
KAFKA-20524: Improve reset offset usability ci-approved clients tools
#22607 opened Jun 17, 2026 by AndrewJSchofield Member Loading…
3
MINOR: Remove jqwik dependency build Gradle build or GitHub Actions kraft
#22604 opened Jun 17, 2026 by mimaison Member Loading…
2
KAFKA-20710: Share coordinator - Fence stale periodic jobs KIP-932 Queues for Kafka
#22603 opened Jun 17, 2026 by Shekharrajak Contributor Loading…
7
KAFKA-20678: Support share group DLQ remote record fetch. ci-approved core Kafka Broker KIP-932 Queues for Kafka triage PRs from the community
#22601 opened Jun 17, 2026 by smjn Collaborator Loading…
1
KAFKA-19583: fix: enable oauthbearer sasl with native image clients small Small PRs triage PRs from the community
#22599 opened Jun 17, 2026 by wilmerdooley Loading…
4 tasks
KAFKA-19543: fix(consumer): keep metrics available after close clients consumer triage PRs from the community
#22598 opened Jun 17, 2026 by wilmerdooley Loading…
4 of 7 tasks
KAFKA-20491: Add uncommitted bytes limit streams
#22597 opened Jun 17, 2026 by nicktelford Contributor Loading…
11
KAFKA-20116: Make task-offset-sum available to client background thread (1/N) clients consumer core Kafka Broker kip Requires or implements a KIP streams
#22595 opened Jun 17, 2026 by mjsax Member Loading…
16
KAFKA-15701: Expose the requesting principal to CreateTopicPolicy and AlterConfigPolicy ci-approved clients kip Requires or implements a KIP kraft triage PRs from the community
#22594 opened Jun 16, 2026 by danoSF Loading…
1
KAFKA-12759: Rebalance when a static member's subscription changes (classic protocol) ci-approved core Kafka Broker group-coordinator triage PRs from the community
#22593 opened Jun 16, 2026 by danoSF Loading…
KAFKA-20693: Fix NPE in AbstractHerder config-validation error handling connect small Small PRs triage PRs from the community
#22592 opened Jun 16, 2026 by wilmerdooley Loading…
KAFKA-19042 Move AuthorizerIntegrationTest to client-integration-tests module build Gradle build or GitHub Actions ci-approved clients tests Test fixes (including flaky tests) tools
#22591 opened Jun 16, 2026 by majialoong Contributor Loading…
1
KAFKA-20699: TopologyTestDriver.getStateStore must not reset the record context ci-approved small Small PRs streams
#22590 opened Jun 16, 2026 by SouquieresAdam Loading…
3
ProTip! Filter pull requests by the default branch with base:trunk.