Skip to content

Pull requests: apache/kafka

New pull request New
339 Open 21,738 Closed
339 Open 21,738 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: Cleanup TestUtils.scala core Kafka Broker tests Test fixes (including flaky tests) tools triage PRs from the community
#22091 opened Apr 18, 2026 by m1a2st Collaborator Loading…
KAFKA-20452: Avoid creating unnecessary empty batches in LogCleaner below the High Watermark ci-approved core Kafka Broker storage Pull requests that target the storage module triage PRs from the community
#22089 opened Apr 18, 2026 by JiayaoS Contributor Loading…
5
KAFKA-20454: Prevent offset reset for streams groups in kafka-consumer-groups.sh tools triage PRs from the community
#22087 opened Apr 17, 2026 by sstremler Contributor Loading…
MINOR: Integration test for demo of restoration race condition streams
#22086 opened Apr 17, 2026 by bbejeck Member Loading…
KAFKA-20456: Use lighter options for RocksDB offsets column family small Small PRs streams
#22085 opened Apr 17, 2026 by bbejeck Member Loading…
MINOR: add DCL on get or create meter for performance improvement ci-approved core Kafka Broker small Small PRs triage PRs from the community
#22084 opened Apr 17, 2026 by YutaLin Contributor Loading…
2
KAFKA-16937 Inline Time#waitObject to ProducerMetadata#awaitUpdate clients producer
#22083 opened Apr 17, 2026 by FrankYang0529 Member Loading…
Add Mini HTTP Client - Kafka design patterns learning project
#22082 opened Apr 17, 2026 by TinaTong-coder Loading…
KAFKA-20245: DLQ records exceeding max delivery count. [3/N] ci-approved core Kafka Broker KIP-932 Queues for Kafka
#22080 opened Apr 17, 2026 by smjn Collaborator • Draft
KAFKA-9914: Fix replication cycle detection connect mirror-maker-2 small Small PRs triage PRs from the community
#22079 opened Apr 17, 2026 by tvainika Loading…
KAFKA-16263: Add listeners and callbacks section to Streams developer guide ci-approved docs streams
#22078 opened Apr 16, 2026 by minjcho Loading…
KAFKA-20384: Add a unit test for reproducing per-record context clients consumer tests Test fixes (including flaky tests) triage PRs from the community
#22077 opened Apr 16, 2026 by adikou Loading…
KAFKA-20461: Support -1 (infinite retention) for offsets.retention.minutes group-coordinator small Small PRs triage PRs from the community
#22076 opened Apr 16, 2026 by edward-b-1 Loading…
1
KAFKA-20443: Move RequestChannel Requests to server module core Kafka Broker performance
#22075 opened Apr 16, 2026 by mimaison Member Loading…
KAFKA-20253: Trigger rejoin on heartbeat thread AuthenticationException clients consumer small Small PRs triage PRs from the community
#22073 opened Apr 16, 2026 by ChoMinGi Contributor Loading…
KAFKA-20455: Wait for all producers to send startup_complete before executing system test small Small PRs tests Test fixes (including flaky tests)
#22071 opened Apr 15, 2026 by kirktrue Contributor Loading…
2
KAFKA-20441: Fix handling of cordoned log dirs kraft small Small PRs
#22070 opened Apr 15, 2026 by mimaison Member Loading…
7
MINOR: Document transaction.timeout.ms behavior under EOS in Streams config guide docs small Small PRs
#22067 opened Apr 15, 2026 by lucasbru Member Loading…
4
MINOR: Replace Collections factory methods with Java 11+ equivalents in clients ci-approved clients small Small PRs
#22060 opened Apr 14, 2026 by see-quick Contributor Loading…
8
KAFKA-20314: Update GraalVM to version 25 to fix native image segfault on startup docker Official Docker image small Small PRs
#22059 opened Apr 14, 2026 by sstremler Contributor Loading…
6
KAFKA-20450 : Fix : Allowlist based SafeObjectInputStream connect small Small PRs triage PRs from the community
#22056 opened Apr 14, 2026 by subbudvk Loading…
6
KAFKA-20448: Fix Docker JVM image build when using local kafka archive docker Official Docker image small Small PRs triage PRs from the community
#22054 opened Apr 14, 2026 by sstremler Contributor Loading…
KAFKA-20437: Fix ssl.enabled.protocols dynamic reconfiguration not being applied clients small Small PRs triage PRs from the community
#22051 opened Apr 14, 2026 by kwondh5217 Contributor Loading…
Add OpenLineage extension for Kafka Connect build Gradle build or GitHub Actions connect kip Requires or implements a KIP triage PRs from the community
#22050 opened Apr 14, 2026 by rahul-madaan • Draft
1
KAFKA-20440: Use default Keystore type instead of hardcoding PKCS12 keystore type clients small Small PRs
#22041 opened Apr 13, 2026 by scholzj Member Loading…
ProTip! Updated in the last three days: updated:>2026-04-15.