Skip to content

Pull requests: apache/kafka

New pull request New
325 Open 21,511 Closed
325 Open 21,511 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-20173: Propagate headers into serde 6/N streams triage PRs from the community
#21850 opened Mar 22, 2026 by UladzislauBlok Loading…
KAFKA-20341: Clarify return semantics of assignment(), subscription(), and metrics() in consumer Javadoc clients consumer small Small PRs triage PRs from the community
#21849 opened Mar 22, 2026 by DL1231 Loading…
9
Feat/mm2 fault tolerance build Gradle build or GitHub Actions clients connect consumer core Kafka Broker dependencies Pull requests that update a dependency file docker Official Docker image 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
#21848 opened Mar 21, 2026 by rjain2778 Loading…
KAFKA-20346: LogCleaner#cleaners should be thread-safe core Kafka Broker storage Pull requests that target the storage module triage PRs from the community
#21847 opened Mar 21, 2026 by TaiJuWu • Draft
MINOR: Fix potential NPE
#21846 opened Mar 21, 2026 by AndrewJSchofield Loading…
2
KAFKA-20050: Add syntax highlighting for code blocks and commands docs triage PRs from the community
#21845 opened Mar 21, 2026 by gomudayya Loading…
KAFKA-19752: Move UnifiedLogTest to storage module core Kafka Broker storage Pull requests that target the storage module tests Test fixes (including flaky tests) triage PRs from the community
#21844 opened Mar 21, 2026 by TaiJuWu Loading…
KAFKA-20343: Refactor LogCleanerLagIntegrationTest to use a builder for LogCleaner setup storage Pull requests that target the storage module tests Test fixes (including flaky tests) triage PRs from the community
#21843 opened Mar 21, 2026 by nileshkumar3 Loading…
KAFKA-19937: Introduced Shared ReaperThread for Persister / NetworkPartitionMetadataClient core Kafka Broker triage PRs from the community
#21842 opened Mar 20, 2026 by rionmonster Loading…
KAFKA-20328 : Adding missing test files - streams headers streams triage PRs from the community
#21841 opened Mar 20, 2026 by muralibasani Loading…
KAFKA-20335: Document KIP-1271 headers-aware state stores docs small Small PRs triage PRs from the community
#21840 opened Mar 20, 2026 by nileshkumar3 • Draft
MINOR: follow-up of KAFKA-20317 ci-approved streams
#21838 opened Mar 20, 2026 by frankvicky Loading…
MINOR: Remove boilerplate code from header serializer test ci-approved small Small PRs streams
#21837 opened Mar 20, 2026 by iit2009060 Loading…
7
MINOR: mark flaky test build Gradle build or GitHub Actions group-coordinator small Small PRs
#21836 opened Mar 20, 2026 by lianetm Loading…
2
MINOR: Fix headers in KTableMapValues and KTableTransformValues ci-approved small Small PRs streams
#21835 opened Mar 20, 2026 by aliehsaeedii Loading…
1
KAFKA-14487: Move LogManager to storage module clients core Kafka Broker performance storage Pull requests that target the storage module tools
#21834 opened Mar 20, 2026 by mimaison Loading…
4
MM2: Add offset gap detection and basic topic reset handling in MirrorSourceTask connect mirror-maker-2 small Small PRs triage PRs from the community
#21831 opened Mar 20, 2026 by PoojanSmart • Draft
KAFKA-20224: Refactor Streams iterator adapters to reduce duplication ci-approved kip Requires or implements a KIP streams
#21830 opened Mar 20, 2026 by nileshkumar3 Loading…
8
MINOR: simplify window-byte-store-supplier kip Requires or implements a KIP streams
#21829 opened Mar 19, 2026 by mjsax Loading…
8
KAFKA-20310: Persist previousProducerId and nextProducerId in transaction log small Small PRs transactions Transactions and EOS triage PRs from the community
#21828 opened Mar 19, 2026 by haltandcatchwater Loading…
KAFKA-20329: Test headers dsl.store.format further (4/N) streams tests Test fixes (including flaky tests) triage PRs from the community
#21827 opened Mar 19, 2026 by aliehsaeedii Loading…
KAFKA-14922: Fail fast if application.id does not exist as consumer group in StreamsResetter ci-approved streams tools
#21826 opened Mar 19, 2026 by Preethi-Sundaravelu Loading…
KAFKA-20330: Ack handling improvement on broker restart clients consumer KIP-932 Queues for Kafka
#21824 opened Mar 19, 2026 by AndrewJSchofield Loading…
7
MINOR: Cleanups in Tools module small Small PRs tools triage PRs from the community
#21823 opened Mar 19, 2026 by sjhajharia Loading…
KAFKA-20240: Update upgrade.md for new KIP-1263 configs in 4.3 docs small Small PRs triage PRs from the community
#21822 opened Mar 19, 2026 by squah-confluent Loading…
ProTip! Exclude everything labeled bug with -label:bug.