Skip to content

Pull requests: apache/kafka

New pull request New
526 Open 22,675 Closed
526 Open 22,675 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 --subscribed-regex to VerifiableConsumer small Small PRs tools triage PRs from the community
#23290 opened Aug 27, 2026 by dongnuo123 Contributor Loading…
MINOR: Add explicit timestamps to WallclockTimestampExtractorTest ci-approved small Small PRs streams tests Test fixes (including flaky tests) triage PRs from the community
#23289 opened Aug 27, 2026 by Parkerhiphop Contributor Loading…
KAFKA-20025: Reload KRaft Raft controller-quorum SSL keystore on dynamic update core Kafka Broker triage PRs from the community
#23288 opened Aug 26, 2026 by sidb98 Loading…
KAFKA-20992: Remove hamcrest from org.apache.kafka.test package ci-approved small Small PRs streams tests Test fixes (including flaky tests)
#23287 opened Aug 26, 2026 by hysuuuu Contributor Loading…
7
MINOR: Remove redundant local variable in KTableSuppressProcessorMetricsTest ci-approved streams tests Test fixes (including flaky tests)
#23286 opened Aug 26, 2026 by Mirai1129 Contributor Loading…
2
KAFKA-20940: Windowed changelog restore optimization is skipped whenever a checkpointed offset exists streams triage PRs from the community
#23285 opened Aug 26, 2026 by alanlau28 Contributor Loading…
KAFKA-20989: Add Notification Cleaners to Migrating Controller Servers
#23284 opened Aug 26, 2026 by yismail-stripe Loading…
1 task done
MINOR: Fix flaky testDescribeQuorumRequestToControllers and testCannotResignIfObserver ci-approved core Kafka Broker kraft small Small PRs tests Test fixes (including flaky tests) triage PRs from the community
#23283 opened Aug 26, 2026 by kevin-wu24 Contributor Loading…
KAFKA-20991 Remove hamcrest from org.apache.kafka.streams.tests package ci-approved small Small PRs streams tests Test fixes (including flaky tests)
#23282 opened Aug 26, 2026 by kuoche1712003 Contributor Loading…
1
KAFKA-18744: reuse LoginCallbackHandler on Kerberos re-login clients triage PRs from the community
#23281 opened Aug 26, 2026 by MdTanwer Loading…
KAFKA-14218: Replace temp file handler with JUnit 5 @TempDir in connect tests connect small Small PRs tests Test fixes (including flaky tests) triage PRs from the community
#23280 opened Aug 26, 2026 by KhyatiVaghamshi Loading…
4 tasks done
1
KAFKA-20988: Remove hamcrest from streams test fixtures build Gradle build or GitHub Actions ci-approved streams
#23279 opened Aug 26, 2026 by shantanushukla Contributor Loading…
3
MINOR: Replace try/fail/catch with assertThrows in producer tests ci-approved clients producer small Small PRs tests Test fixes (including flaky tests) triage PRs from the community
#23277 opened Aug 25, 2026 by hjtiun852 Contributor Loading…
1
MINOR: use ConfigDef.parseType for rack aware tag ci-approved group-coordinator small Small PRs triage PRs from the community
#23276 opened Aug 25, 2026 by gabriellefu Contributor Loading…
fix(utils): make humanReadableByteCount thread-safe via ThreadLocal DecimalFormat clients small Small PRs triage PRs from the community
#23274 opened Aug 25, 2026 by shoemoney Loading…
MINOR: Reject frame version, type and version varints that decode negative core Kafka Broker kraft small Small PRs triage PRs from the community
#23273 opened Aug 25, 2026 by MahathirMohammadShuvo Loading…
MINOR: Speed up Streams restart integration tests ci-approved streams tests Test fixes (including flaky tests) triage PRs from the community
#23272 opened Aug 25, 2026 by Russole Contributor Loading…
MINOR: Address suppress HEADERS system test follow-ups ci-approved small Small PRs streams tests Test fixes (including flaky tests)
#23269 opened Aug 25, 2026 by aliehsaeedii Contributor Loading…
3
KAFKA-15976: Allow specifying initial offsets while creating connectors connect triage PRs from the community
#23268 opened Aug 25, 2026 by psiby Loading…
MINOR: Additional cleanup in AlterConfigs core Kafka Broker group-coordinator small Small PRs triage PRs from the community
#23267 opened Aug 25, 2026 by omkreddy Contributor Loading…
KAFKA-20985: Keep static member id when LeaveGroup is suppressed clients consumer small Small PRs triage PRs from the community
#23266 opened Aug 25, 2026 by suzhiking Contributor Loading…
MINOR: Stable flaky e2e test share_consumer_dlq_tiered_storage_test (WIP) small Small PRs tests Test fixes (including flaky tests) triage PRs from the community
#23264 opened Aug 25, 2026 by m1a2st Contributor Loading…
KAFKA-20981: fail on an unknown status code in the Streams heartbeat response clients consumer KIP-1071 PRs related to KIP-1071 small Small PRs streams
#23262 opened Aug 25, 2026 by mjsax Member Loading…
1
MINOR: Add Protobuf message formatter for kafka-console-consumer build Gradle build or GitHub Actions ci-approved dependencies Pull requests that update a dependency file tools triage PRs from the community
#23260 opened Aug 24, 2026 by ssbytedev Loading…
KAFKA-20979: Ensure indexes resize are fsynced when shutting down small Small PRs storage Pull requests that target the storage module
#23258 opened Aug 24, 2026 by mimaison Member Loading…
9
ProTip! Type g i on any issue or pull request to go back to the issue listing page.