Skip to content

Pull requests: apache/kafka

New pull request New
435 Open 22,180 Closed
435 Open 22,180 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: 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-20624: Wire topology description plugin into GroupCoordinatorService — read path (describe) and broker wiring core Kafka Broker group-coordinator
#22627 opened Jun 19, 2026 by frankvicky Contributor Loading…
@lucasbru
5
KAFKA-20494: Transactional InMemoryKeyValueStore streams
#22626 opened Jun 19, 2026 by nicktelford Contributor Loading…
5
KAFKA-20493: Transactional RocksDBStore build Gradle build or GitHub Actions streams
#22625 opened Jun 19, 2026 by nicktelford Contributor Loading…
7
MINOR: Bump Setup Gradle to 6.2.0 build Gradle build or GitHub Actions small Small PRs
#22624 opened Jun 19, 2026 by mimaison Member Loading…
MINOR: Improve handling adding metadata versions ci-approved core Kafka Broker small Small PRs tools triage PRs from the community
#22623 opened Jun 19, 2026 by see-quick 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
3
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-20712: Fix transaction state name in log decoder output ci-approved small Small PRs tools
#22615 opened Jun 18, 2026 by fvaleri Contributor Loading…
7
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…
KAFKA-19871 - Add partition support to TestRecord ci-approved streams tests Test fixes (including flaky tests)
#22612 opened Jun 18, 2026 by sebastienviale Contributor Loading…
@lucasbru
33
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…
8
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-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…
17
ProTip! Find all pull requests that aren't related to any open issues with -linked:issue.