Skip to content

Pull requests: apache/kafka

New pull request New
327 Open 21,352 Closed
327 Open 21,352 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: Migrate NodeToControllerRequestThreadTest from Scala to Java core Kafka Broker tests Test fixes (including flaky tests) triage PRs from the community
#21693 opened Mar 10, 2026 by DL1231 Loading…
KAFKA-20066: Implement KIP-1251: Assignment epochs for consumer groups [3/N] group-coordinator
#21692 opened Mar 9, 2026 by lucliu1108 Loading…
@lucasbru
5
KAFKA-15852: Move UncleanLeaderElectionTest to server module core Kafka Broker
#21689 opened Mar 9, 2026 by mimaison Loading…
9
KAFKA-20281: Enhance helper message for producer-props and command-property small Small PRs tools
#21688 opened Mar 9, 2026 by FrankYang0529 Loading…
1
KAFKA-19752 Move parts of UnifiedLogTest to storage module core Kafka Broker storage Pull requests that target the storage module triage PRs from the community
#21686 opened Mar 9, 2026 by m1a2st Loading…
MINOR: Fix broken documentation links for Streams Rebalance Protocol docs small Small PRs
#21685 opened Mar 9, 2026 by lucasbru Loading…
1
KAFKA-20173: Metered layer of KV-stores needs to pass Headers kip Requires or implements a KIP streams
#21684 opened Mar 9, 2026 by mjsax Loading…
12
MINOR: improve generic type safety for IQv2 in metered-store layer streams
#21683 opened Mar 9, 2026 by mjsax Loading…
6
KAFKA-20158: Adding SessionStore with headers adapters and iterator facade streams
#21680 opened Mar 8, 2026 by bbejeck Loading…
8
Address KAFKA-20252: Migrate clearYammerMetrics to TestUtils clients core Kafka Broker KIP-932 Queues for Kafka small Small PRs storage Pull requests that target the storage module tests Test fixes (including flaky tests) tiered-storage Related to the Tiered Storage feature
#21679 opened Mar 8, 2026 by dubeyKartikay Loading…
6
KAFKA-20160: Group configuration for share.partition.max.record.locks clients core Kafka Broker group-coordinator KIP-932 Queues for Kafka
#21678 opened Mar 8, 2026 by mingyen066 Loading…
13
KAFKA-19983: Fix MockProcessorContext doesn't work with WindowStores. streams triage PRs from the community
#21677 opened Mar 8, 2026 by chickenchickenlove • Draft
2
KAFKA-20179 : Avoid headers deserialization during changelogging streams triage PRs from the community
#21676 opened Mar 8, 2026 by muralibasani • Draft
1
MINOR: refactor AbstractSegmentsTests to reduce redundancies streams
#21674 opened Mar 8, 2026 by mjsax Loading…
28
KAFKA-20077: Prevent infinite AddPartitionsToTxn retries causing producer.flush() to hang clients producer small Small PRs triage PRs from the community
#21672 opened Mar 8, 2026 by nileshkumar3 Loading…
2
KAFKA-16600: Periodically receive "Failed to transition to PENDING_SHUTDOWN, current state is PENDING_SHUTDOWN" during streams close small Small PRs streams triage PRs from the community
#21671 opened Mar 8, 2026 by kirktrue • Draft
KAFKA-20277: Add session store with headers support for IQv2 streams
#21670 opened Mar 8, 2026 by bbejeck Loading…
KAFKA-20131: ClassicKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls ci-approved
#21669 opened Mar 7, 2026 by kirktrue Loading…
KAFKA-20260: Upgrade path from plain KV store to headers store streams
#21666 opened Mar 7, 2026 by aliehsaeedii Loading…
18
KAFKA-13630: Reduce deque lock scope in RecordAccumulator.drainBatchesForOneNode clients producer small Small PRs triage PRs from the community
#21665 opened Mar 7, 2026 by nileshkumar3 Loading…
4
KAFKA-20269: Refactor target assignment update for delayed assignments ci-approved group-coordinator
#21664 opened Mar 7, 2026 by squah-confluent Loading…
5
MINOR: refactor warning message core Kafka Broker small Small PRs
#21661 opened Mar 6, 2026 by brandboat Loading…
2
KAFKA-20270 build Gradle build or GitHub Actions dependencies Pull requests that update a dependency file small Small PRs
#21660 opened Mar 6, 2026 by averemee-si Loading…
5
MINOR: Replace Collections factory methods with Java 11+ equivalents in storage and metadata ci-approved kraft small Small PRs storage Pull requests that target the storage module
#21659 opened Mar 6, 2026 by see-quick Loading…
4
KAFKA-20267 Move LogCleanerParameterizedIntegrationTest to storage module ci-approved core Kafka Broker storage Pull requests that target the storage module tests Test fixes (including flaky tests)
#21657 opened Mar 6, 2026 by see-quick Loading…
1
ProTip! What’s not been updated in a month: updated:<2026-02-09.