Skip to content

Pull requests: apache/kafka

New pull request New
344 Open 21,901 Closed
344 Open 21,901 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: Assert queryable state range results small Small PRs streams tests Test fixes (including flaky tests) triage PRs from the community
#22259 opened May 12, 2026 by codingkiddo Loading…
MINOR: Add documentation for the num-keys metric introduced by KIP-1250 ci-approved docs small Small PRs triage PRs from the community
#22258 opened May 11, 2026 by ezhou413 Contributor Loading…
KAFKA-20566: Improve logging in share coordinator KIP-932 Queues for Kafka small Small PRs
#22257 opened May 11, 2026 by AndrewJSchofield Member Loading…
1
KAFKA-20565 : Fix flaky test testAutoCommitSentBeforePositionUpdate timeout ci-approved clients consumer small Small PRs tests Test fixes (including flaky tests)
#22256 opened May 11, 2026 by muralibasani Contributor • Draft
docs: Document actual ProducerRecord default partitioner strategy clients producer small Small PRs triage PRs from the community
#22253 opened May 11, 2026 by dbottini2 Loading…
MINOR: Rewrite FetchFromFollowerIntegrationTest from Scala to Java and move to server module ci-approved clients core Kafka Broker tests Test fixes (including flaky tests)
#22252 opened May 11, 2026 by cychiu8 Contributor Loading…
10
KAFKA-20553 : Eliminate the dependencies on sourceSets.test.output for metadata build Gradle build or GitHub Actions ci-approved core Kafka Broker kraft
#22247 opened May 10, 2026 by muralibasani Contributor Loading…
21
KAFKA-20539 Prevent Hot Data Loss on Partition Expansion for Latest Policy (WIP) clients core Kafka Broker kraft tools triage PRs from the community
#22246 opened May 10, 2026 by m1a2st Collaborator Loading…
KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol (1/N) group-coordinator triage PRs from the community
#22245 opened May 10, 2026 by chickenchickenlove Contributor Loading…
1
KAFKA-20385: Add consumer-aware methods to ConsumerRebalanceListener clients consumer streams
#22242 opened May 8, 2026 by adikou Loading…
7
KAFKA-14227 Support for nested structures: MaskField connect triage PRs from the community
#22240 opened May 7, 2026 by hgeraldino Contributor • Draft
2
KAFKA-14229 Support for nested structures: HoistField connect triage PRs from the community
#22237 opened May 7, 2026 by hgeraldino Contributor Loading…
KAFKA-14228 Support for nested structures: ValueToKey connect triage PRs from the community
#22235 opened May 7, 2026 by hgeraldino Contributor Loading…
1
KAFKA-20554: Document acks=1 record loss during planned leader transitions clients producer small Small PRs
#22233 opened May 7, 2026 by julianbergner Loading…
5
MINOR: TopologyTestDriver can reuse compiled Patterns for topic names small Small PRs streams triage PRs from the community
#22228 opened May 6, 2026 by stevenschlansker Contributor Loading…
MINOR: Rewrite LogCleanerTest in Java and move it to storage module ci-approved core Kafka Broker storage Pull requests that target the storage module
#22225 opened May 6, 2026 by majialoong Contributor Loading…
14
KAFKA-10844: KStream mark as partitioned streams
#22221 opened May 6, 2026 by zheguang Contributor Loading…
8
KSTREAMS-8781: Add back rack.aware.assignment.tags config ci-approved clients consumer core Kafka Broker group-coordinator
#22213 opened May 5, 2026 by gabriellefu Contributor Loading…
16
initial config build Gradle build or GitHub Actions clients connect consumer core Kafka Broker generator RPC and Record code generator group-coordinator KIP-932 Queues for Kafka kraft mirror-maker-2 performance producer storage Pull requests that target the storage module streams tiered-storage Related to the Tiered Storage feature tools transactions Transactions and EOS triage PRs from the community
#22212 opened May 5, 2026 by traceyyoshima • Draft
KAFKA-18389: Preserve votedKey when transitioning to leader state kraft
#22203 opened May 4, 2026 by lh0156 Loading…
5
KAFKA-17164: Enforce 'application.server' <server>:<port> format at config level. small Small PRs streams
#22202 opened May 4, 2026 by chickenchickenlove Contributor Loading…
18
Caching immutable voterKeys kraft needs-attention small Small PRs triage PRs from the community
#22198 opened May 3, 2026 by ppatierno Contributor Loading…
1
KAFKA-20524: CSV reset offset plan for kafka-share-groups.sh KIP-932 Queues for Kafka tools
#22197 opened May 2, 2026 by AndrewJSchofield Member Loading…
12
KAFKA-20328 : Part 1 - headers-aware api test coverage needs-attention streams tests Test fixes (including flaky tests) triage PRs from the community
#22196 opened May 2, 2026 by muralibasani Contributor Loading…
2
MINOR: Switched RecordAccumulator.append from ByteBuffer to ByteBufferOutputStream. clients needs-attention producer small Small PRs triage PRs from the community
#22192 opened May 1, 2026 by Nikita-Shupletsov Contributor Loading…
1
ProTip! Add no:assignee to see everything that’s not assigned.