Skip to content

Pull requests: apache/kafka

New pull request New
375 Open 21,978 Closed
375 Open 21,978 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

Feat: Hardening MirrorMaker 2 Replication Pipeline with Truncation Recovery triage PRs from the community
#22367 opened May 25, 2026 by rajabhishekmaurya Loading…
KAFKA-20603 : Replace MemoryLRUCache restoring flag with restore lifecycle hooks ci-approved clients consumer streams triage PRs from the community
#22366 opened May 24, 2026 by muralibasani Contributor Loading…
KAFKA-20549: Implemented PRODUCE RPC handler for DLQ state manager. [5/N] ci-approved core Kafka Broker KIP-932 Queues for Kafka
#22365 opened May 24, 2026 by smjn Collaborator Loading…
KAFKA-20423: Fix flakiness of testWakeupWithFetchDataAvailable clients consumer small Small PRs tests Test fixes (including flaky tests) triage PRs from the community
#22364 opened May 24, 2026 by chickenchickenlove Contributor Loading…
MINOR: Narrow remote copy lag validator props to Map<String, ?> and update the upgrade doc for KIP-1241 ci-approved small Small PRs storage Pull requests that target the storage module triage PRs from the community
#22363 opened May 24, 2026 by jiafu1115 Contributor Loading…
2
Fix typo 'instantiater' -> 'instantiator' in LeaderEpochFileCache Javadoc ci-approved small Small PRs storage Pull requests that target the storage module
#22359 opened May 23, 2026 by RonGamzu Contributor Loading…
2
Fix typo 'amd' -> 'and' in CompletableEventReaperTest comments clients consumer small Small PRs tests Test fixes (including flaky tests)
#22358 opened May 23, 2026 by RonGamzu Contributor Loading…
1
KAFKA-19883: [DRAFT] KIP-1289 — Transactional acknowledgments for share groups (state machine + client API + wire schema) clients consumer core Kafka Broker KIP-932 Queues for Kafka producer
#22357 opened May 23, 2026 by Shekharrajak Contributor • Draft
16
KAFKA-20601: Allow static member rejoin when consumer group is full. group-coordinator triage PRs from the community
#22356 opened May 23, 2026 by chickenchickenlove Contributor Loading…
KAFKA-18948 Move DynamicLogConfig to server module ci-approved core Kafka Broker storage Pull requests that target the storage module
#22353 opened May 23, 2026 by unknowntpo Contributor Loading…
6
MINOR: Added Compression.wrapForInput method for ByteBufferInputStream. clients triage PRs from the community
#22351 opened May 22, 2026 by Nikita-Shupletsov Contributor • Draft
MINOR: Split GroupMetadataManagerTest into per-group-type files ci-approved group-coordinator triage PRs from the community
#22350 opened May 22, 2026 by sjhajharia Collaborator Loading…
MINOR: Reduce close delay in testFailureToFenceEpoch ci-approved small Small PRs storage Pull requests that target the storage module tests Test fixes (including flaky tests)
#22347 opened May 22, 2026 by JiayaoS Contributor Loading…
3
MINOR: Move inter-broker NetworkClient factory to server module ci-approved core Kafka Broker small Small PRs
#22346 opened May 22, 2026 by JiayaoS Contributor Loading…
8
KAFKA-15038: Remove topicIdByPartitionMap from RemoteLogManager ci-approved core Kafka Broker storage Pull requests that target the storage module tiered-storage Related to the Tiered Storage feature triage PRs from the community
#22345 opened May 22, 2026 by JiayaoS Contributor Loading…
1
MINOR: extracted the majority of the logic from MemoryRecordsBuilder to an abstract class. clients producer storage Pull requests that target the storage module triage PRs from the community
#22344 opened May 21, 2026 by Nikita-Shupletsov Contributor • Draft
KAFKA-20404: Replace bulk StreamsPartitionAssignor atomicity exclude with field-level suppressions build Gradle build or GitHub Actions ci-approved small Small PRs triage PRs from the community
#22341 opened May 21, 2026 by Phixsura Loading…
KAFKA-20404: Replace bulk TaskManager atomicity exclude with a field-level suppression build Gradle build or GitHub Actions small Small PRs triage PRs from the community
#22340 opened May 21, 2026 by Phixsura Loading…
MINOR: Split KafkaAdminClientTest into per-domain test classes ci-approved clients
#22339 opened May 21, 2026 by sjhajharia Collaborator Loading…
8
KAFKA-8073: Fix flaky BaseQuotaTest.testThrottledProducerConsumer ci-approved core Kafka Broker small Small PRs tests Test fixes (including flaky tests) triage PRs from the community
#22338 opened May 21, 2026 by nileshkumar3 Contributor Loading…
2
MINOR: Add 4.3.0 to docker_scan workflow build Gradle build or GitHub Actions small Small PRs
#22337 opened May 20, 2026 by mimaison Member Loading…
1
MINOR: Remove unused Response.onComplete method core Kafka Broker
#22336 opened May 20, 2026 by mimaison Member Loading…
MINOR: Move TransactionStateManager leaf case classes to Java records in transaction-coordinator ci-approved core Kafka Broker transactions Transactions and EOS triage PRs from the community
#22334 opened May 20, 2026 by sjhajharia Collaborator Loading…
KAFKA-20404: Replace bulk DefaultStateUpdater atomicity excludes with field-level suppressions build Gradle build or GitHub Actions ci-approved small Small PRs
#22333 opened May 20, 2026 by Phixsura Loading…
2
KAFKA-14490: Throw UncheckedIOException from LazyIndex ci-approved storage Pull requests that target the storage module triage PRs from the community
#22330 opened May 19, 2026 by Phixsura Loading…
1
ProTip! Exclude everything labeled bug with -label:bug.