Skip to content

Pull requests: apache/kafka

New pull request New
462 Open 22,458 Closed
462 Open 22,458 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-20877: Fix incorrect restore-rate and update-rate metrics small Small PRs streams
#23009 opened Jul 31, 2026 by mjsax Member Loading…
KAFKA-20864: Fix to avoid early batch close if extension fails clients producer
#23008 opened Jul 31, 2026 by lianetm Member Loading…
KAFKA-20849: Update the headers-aware store docs on suppress() ci-approved docs kip Requires or implements a KIP small Small PRs streams
#23007 opened Jul 31, 2026 by aliehsaeedii Contributor Loading…
5
KAFKA-20868: Add warmup tasks to IQ metadata clients group-coordinator small Small PRs triage PRs from the community
#23006 opened Jul 31, 2026 by gabriellefu Contributor Loading…
KAFKA-20874: Close SslFactory in JaasOptionsUtils.createSSLSocketFactory() clients small Small PRs triage PRs from the community
#23005 opened Jul 31, 2026 by fvaleri Contributor Loading…
KAFKA-20873: Fix deadlock between removeStreamThread and addStreamThread streams triage PRs from the community
#23004 opened Jul 31, 2026 by frankvicky Contributor Loading…
MINOR: Remove EnrichedSourceConnectorConfig ci-approved connect small Small PRs
#23003 opened Jul 31, 2026 by dino2895 Contributor Loading…
1
KAFKA-20870: Add test for the owned-task report for a single-role assignment change clients consumer small Small PRs streams tests Test fixes (including flaky tests)
#23002 opened Jul 31, 2026 by mjsax Member Loading…
KAFKA-20861: Kafka Streams should handle corrupted assignments pro-actively clients consumer
#22999 opened Jul 31, 2026 by mjsax Member Loading…
1
[DO NOT MERGE]KAFKA-20867: Upgrade RocksDB dependency from 10.1.3 to 10.10.1 build Gradle build or GitHub Actions dependencies Pull requests that update a dependency file small Small PRs streams triage PRs from the community
#22998 opened Jul 30, 2026 by lucliu1108 Contributor • Draft
KAFKA-20576: Adding benchmark for producer append performance
#22997 opened Jul 30, 2026 by lianetm Member • Draft
KAFKA-20858: Refactor subscription state clients consumer performance
#22996 opened Jul 30, 2026 by AndrewJSchofield Member Loading…
KAFKA-20862 update gradle-versions-plugin to improve dependencyUpdates task result output build Gradle build or GitHub Actions small Small PRs triage PRs from the community
#22995 opened Jul 30, 2026 by dejan2609 Contributor Loading…
1
MINOR: Fix StreamPartitioner removal warnings in integration tests ci-approved streams tests Test fixes (including flaky tests) triage PRs from the community
#22993 opened Jul 30, 2026 by dino2895 Contributor Loading…
KAFKA-20328: [2/N] headers-aware decorator/forwarder test coverage streams tests Test fixes (including flaky tests) triage PRs from the community
#22992 opened Jul 29, 2026 by muralibasani Contributor Loading…
1
MINOR: improve "streams" default rebalance listener streams
#22991 opened Jul 29, 2026 by mjsax Member Loading…
1
MINOR: ensure ps output is unlimited width ci-approved docker Official Docker image small Small PRs
#22990 opened Jul 29, 2026 by gaurav-narula Contributor Loading…
1
KAFKA-20828: Centralize client throttling version logic ci-approved clients
#22989 opened Jul 29, 2026 by arnabnandy7 Contributor Loading…
6
MINOR: Move RequestConvertToJsonTest to server module core Kafka Broker tests Test fixes (including flaky tests)
#22988 opened Jul 29, 2026 by mimaison Member Loading…
1
MINOR: allow running docker tests with kafka-archive ci-approved docker Official Docker image small Small PRs triage PRs from the community
#22987 opened Jul 29, 2026 by gaurav-narula Contributor Loading…
KAFKA-20430 Fix getTopicConfig() for connector-specific offset stores ci-approved connect
#22984 opened Jul 29, 2026 by kaijaytu Loading…
5
KAFKA-20847: Carry record metadata on suppress buffer changelog tombstones small Small PRs streams triage PRs from the community
#22983 opened Jul 29, 2026 by nileshkumar3 Contributor Loading…
KAFKA-20792: Fix invalid partition -1 in FK join triggered by punctuator streams triage PRs from the community
#22980 opened Jul 28, 2026 by siddharthaDevineni Contributor Loading…
MINOR: De-duplicate Metered*WithHeaders read-only-record iterators streams triage PRs from the community
#22975 opened Jul 28, 2026 by Jess668 Contributor Loading…
KAFKA-20851 spotless gradle plugin version update: 8.4.0 -->> 8.9.0 build Gradle build or GitHub Actions small Small PRs triage PRs from the community
#22973 opened Jul 28, 2026 by dejan2609 Contributor Loading…
2
ProTip! Follow long discussions with comments:>50.