Skip to content

Pull requests: apache/kafka

New pull request New
250 Open 20,035 Closed
250 Open 20,035 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-19481: Fix flaky test testConsumerGroupHeartbeatWithRegex core Kafka Broker small Small PRs tests Test fixes (including flaky tests) triage PRs from the community
#20298 opened Aug 4, 2025 by jmmonte2 Loading…
MINOR: Replace boundPort with brokerBoundPort ci-approved clients core Kafka Broker small Small PRs tests Test fixes (including flaky tests)
#20297 opened Aug 3, 2025 by jim0987795064 Loading…
Kafka streams api enhanced streams triage PRs from the community
#20296 opened Aug 2, 2025 by vamsisayimpu Loading…
MINOR: Run CI with Java 24 build Gradle build or GitHub Actions small Small PRs triage PRs from the community
#20295 opened Aug 2, 2025 by srdo Loading…
1
MINOR: Upgrade Spotbugs to 4.9.1 build Gradle build or GitHub Actions triage PRs from the community
#20294 opened Aug 2, 2025 by srdo Loading…
KAFKA-19537: Improve Exit Code Handling in StreamsGroupCommand ci-approved tools triage PRs from the community
#20293 opened Aug 2, 2025 by joshua2519 Loading…
KAFKA-13152: Replace "buffered.records.per.partition" & "cache.max.bytes.buffering" with "{statestore.cache}/{input.buffer}.max.bytes" streams triage PRs from the community
#20292 opened Aug 2, 2025 by shashankhs11 Loading…
MINOR: Improve skip-record-metadata description core Kafka Broker small Small PRs
#20291 opened Aug 1, 2025 by fvaleri Loading…
7
KAFKA-19572: Added check to prevent NPE logs during ShareConsumer::close ci-approved clients consumer KIP-932 Queues for Kafka
#20290 opened Aug 1, 2025 by ShivsundarR Loading…
KAFKA-19571: Race condition between log segment flush and file deletion causing log dir to go offline small Small PRs storage Pull requests that target the storage module triage PRs from the community
#20289 opened Aug 1, 2025 by itoumlilt Loading…
KAFKA-19570: Implement offline migration for streams groups group-coordinator
#20288 opened Aug 1, 2025 by lucasbru Loading…
6
KAFKA-19479: at_least_once mode in Kafka Streams silently drops messages when the producer fails with MESSAGE_TOO_LARGE, violating delivery guarantees clients producer tests Test fixes (including flaky tests) triage PRs from the community
#20285 opened Jul 31, 2025 by shashankhs11 Loading…
MINOR: retry upon missing source topic ci-approved streams
#20284 opened Jul 31, 2025 by RaidenE1 Loading…
7
KAFKA-18220: Refactor AsyncConsumerMetrics to not extend KafkaConsumerMetrics ci-approved clients consumer KIP-932 Queues for Kafka
#20283 opened Jul 31, 2025 by ShivsundarR Loading…
Added the check for underlying partition being the leader in delayedShareFetch tryComplete methhod ci-approved core Kafka Broker KIP-932 Queues for Kafka
#20280 opened Jul 31, 2025 by chirag-wadhwa5 Loading…
5
MINOR: Note KS broker replication factor limitation docs small Small PRs triage PRs from the community
#20279 opened Jul 31, 2025 by JimGalasyn Loading…
MINOR: Align order or gradle command build Gradle build or GitHub Actions small Small PRs triage PRs from the community
#20278 opened Jul 31, 2025 by Pankraz76 Loading…
KAFKA-19513: Flaky test: AclControlManagerTest.testDeleteExceedsMaxRecords() kraft small Small PRs tests Test fixes (including flaky tests) triage PRs from the community
#20276 opened Jul 31, 2025 by ryu001 Loading…
MINOR: Cleanup RaftClient#upgradeKRaftVersion java document kraft small Small PRs
#20275 opened Jul 31, 2025 by m1a2st Loading…
2
MINOR: kafka-stream-groups.sh should fail quickly if the partition leader is unavailable ci-approved small Small PRs tools triage PRs from the community
#20271 opened Jul 31, 2025 by JimmyWang6 Loading…
1
MINOR: Fix typo in state-change log filename after rotate ci-approved small Small PRs
#20269 opened Jul 30, 2025 by jaredharley Loading…
4
KAFKA-19564: Close Consumer in ConsumerPerformance only after metrics displayed ci-approved tools
#20267 opened Jul 30, 2025 by kirktrue Loading…
KAFKA-19565 Integration test for Streams-related Admin APIs[2/N] admin AdminClient build Gradle build or GitHub Actions ci-approved core Kafka Broker streams tests Test fixes (including flaky tests)
#20266 opened Jul 30, 2025 by lucliu1108 Loading…
KAFKA-17876/ KAFKA-19150 Rename AssignmentsManager and RemoteStorageThreadPool metrics core Kafka Broker small Small PRs storage Pull requests that target the storage module
#20265 opened Jul 30, 2025 by m1a2st Loading…
1
KAFKA-18607: Update jfreechart dependency build Gradle build or GitHub Actions small Small PRs triage PRs from the community
#20264 opened Jul 30, 2025 by fvaleri Loading…
2
ProTip! Add no:assignee to see everything that’s not assigned.