Skip to content

Pull requests: apache/kafka

New pull request New
385 Open 22,021 Closed
385 Open 22,021 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: Add 4.2.1 to upgrade.md
#22419 opened May 30, 2026 by FrankYang0529 Member Loading…
MINOR: Write bootstrap checkpoint only to metadata directories ci-approved kraft small Small PRs triage PRs from the community
#22418 opened May 30, 2026 by majialoong Contributor Loading…
2
KAFKA-10317: Global thread should honor shutdown signal during bootstrapping streams triage PRs from the community
#22417 opened May 29, 2026 by lucliu1108 Contributor Loading…
2
KAFKA-20639: Move EnvelopeUtils to server module ci-approved core Kafka Broker triage PRs from the community
#22416 opened May 29, 2026 by majialoong Contributor Loading…
KAFKA-20618: KIP-1331 Streams Group Topology Description Plugin (POC) build Gradle build or GitHub Actions clients consumer core Kafka Broker group-coordinator streams tools
#22413 opened May 29, 2026 by lucasbru Member • Draft
KAFKA-20612: Stitch DLQ metrics with ShareGroupDLQStateManager. ci-approved core Kafka Broker KIP-932 Queues for Kafka
#22412 opened May 29, 2026 by smjn Collaborator Loading…
KAFKA-19536: Respect grace period for out-of-order stream joins ci-approved small Small PRs streams triage PRs from the community
#22410 opened May 29, 2026 by goutamadwant Loading…
MINOR: Add generic config type to BrokerReconfigurable ci-approved core Kafka Broker small Small PRs storage Pull requests that target the storage module
#22409 opened May 29, 2026 by unknowntpo Contributor Loading…
2
KAFKA-20637: Move ForwardingManager to server module build Gradle build or GitHub Actions core Kafka Broker performance
#22408 opened May 28, 2026 by mimaison Member Loading…
KAFKA-18157: Consider UnsupportedVersionException child class to represent the case of unsupported fields ci-approved clients consumer triage PRs from the community
#22405 opened May 28, 2026 by alanlau28 Loading…
KAFKA-17840: Move ClientRequestQuotaManager to server module core Kafka Broker performance
#22403 opened May 28, 2026 by mimaison Member Loading…
MINOR: Move LoggingController log level resolution test to server ci-approved core Kafka Broker small Small PRs tests Test fixes (including flaky tests) triage PRs from the community
#22402 opened May 28, 2026 by majialoong Contributor Loading…
1
KAFKA-19298: Move RuntimeLoggerManager to server module ci-approved core Kafka Broker small Small PRs
#22401 opened May 28, 2026 by majialoong Contributor Loading…
1
MINOR:Add 4.2.1 to docker_scan workflow build Gradle build or GitHub Actions small Small PRs
#22399 opened May 28, 2026 by FrankYang0529 Member Loading…
MINOR: A starting point for a formal security model docs
#22398 opened May 28, 2026 by clolov Contributor • Draft
12
KAFKA-20620: Add StreamsGroupTopologyDescriptionUpdate RPC schema and extend StreamsGroupDescribe/Heartbeat clients core Kafka Broker
#22397 opened May 28, 2026 by aliehsaeedii Contributor • Draft
1
KAFKA-20633: Update the default value of remote copy lag bytes clients core Kafka Broker storage Pull requests that target the storage module tiered-storage Related to the Tiered Storage feature triage PRs from the community
#22394 opened May 28, 2026 by kamalcph Contributor Loading…
1
KAFKA-20632: Added ChunkedBufferPool that can allocate multiple byte buffers at once. clients producer triage PRs from the community
#22392 opened May 27, 2026 by Nikita-Shupletsov Contributor • Draft
KAFKA-20607: Include docs in version consistency checks and updates build Gradle build or GitHub Actions ci-approved triage PRs from the community
#22391 opened May 27, 2026 by majialoong Contributor Loading…
3
KAFKA-20628 Add TTL-based expiration to PartitionLeaderCache clients triage PRs from the community
#22390 opened May 27, 2026 by hgeraldino Contributor Loading…
[PoC] KIP-1128: Replace KTable.transformValues with KTable.processFixedKey and add new KStreams.processFixedKey streams triage PRs from the community
#22387 opened May 27, 2026 by frankvicky Contributor Loading…
KAFKA-20619: ClusterTestExtensions skip jdk.internal.ref.CleanerImpl … ci-approved small Small PRs tests Test fixes (including flaky tests)
#22386 opened May 27, 2026 by edoardocomar Contributor Loading…
3
KAFKA-20617: add validation for cluster-id in Formatter kraft small Small PRs
#22384 opened May 27, 2026 by gaurav-narula Contributor Loading…
14
MINOR: MM2 surface log-truncation and topic-reset as actionable events in MirrorSourceTask ci-approved connect mirror-maker-2 small Small PRs triage PRs from the community
#22380 opened May 27, 2026 by rajabhishekmaurya Loading…
3 tasks done
KAFKA-19584: add SecurityManager shim support to native image docker Official Docker image small Small PRs triage PRs from the community
#22379 opened May 27, 2026 by gaurav-narula Contributor Loading…
ProTip! Updated in the last three days: updated:>2026-05-27.