-
Notifications
You must be signed in to change notification settings - Fork 14.5k
Pull requests: apache/kafka
Author
Label
Projects
Milestones
Reviews
Assignee
Sort
Pull requests list
KAFKA-19579: Add missing metrics for doc tiered storage
docs
small
Small PRs
triage
PRs from the community
#20304
opened Aug 4, 2025 by
majialoong
Loading…
MINOR: Add test coverage for StorageTool format command feature validation
core
Kafka Broker
kraft
triage
PRs from the community
#20303
opened Aug 4, 2025 by
sjhajharia
Loading…
KAFKA-19574: Improve producer and consumer config files
triage
PRs from the community
#20302
opened Aug 4, 2025 by
fvaleri
Loading…
KAFKA-19011: Improve EndToEndLatency Tool with argument parser and message key/header support
ci-approved
tools
triage
PRs from the community
#20301
opened Aug 4, 2025 by
Rancho-7
Loading…
KAFKA-16768: SocketServer leaks accepted SocketChannel instances due to race condition
core
Kafka Broker
small
Small PRs
triage
PRs from the community
#20300
opened Aug 4, 2025 by
jack2012aa
Loading…
Kafka streams api enhanced
streams
triage
PRs from the community
#20296
opened Aug 2, 2025 by
vamsisayimpu
Loading…
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
ci-approved
core
Kafka Broker
small
Small PRs
#20291
opened Aug 1, 2025 by
fvaleri
Loading…
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…
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…
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…
KAFKA-19567: 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…
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()
ci-approved
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…
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…
Previous Next
ProTip!
Type g p on any issue or pull request to go back to the pull request listing page.