Skip to content

Pull requests: apache/kafka

New pull request New
257 Open 19,624 Closed
257 Open 19,624 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-17853: Fix termination issue in ConsoleConsumer and ConsoleShareConsumer ci-approved clients consumer KIP-932 Queues for Kafka small Small PRs
#19886 opened Jun 3, 2025 by ShivsundarR Loading…
4
KAFKA-15283:[2/2] Client support for OffsetFetch with topic ID clients consumer small Small PRs triage PRs from the community
#19885 opened Jun 3, 2025 by DL1231 Loading…
KAFKA-19324: org.apache.kafka.common.test.TestUtils should be package-private ci-approved clients core Kafka Broker storage Pull requests that target the storage module transactions Transactions and EOS triage PRs from the community
#19884 opened Jun 3, 2025 by YutaLin Loading…
2
KAFKA-18486: Update testExceptionWhenUnverifiedTransactionHasMultipleProducerIds ci-approved core Kafka Broker small Small PRs tests Test fixes (including flaky tests) triage PRs from the community
#19883 opened Jun 3, 2025 by jingjia88 Loading…
KAFKA-18967: Added additional MetadataSchemaCheckerTool tests generator RPC and Record code generator tests Test fixes (including flaky tests) triage PRs from the community
#19882 opened Jun 2, 2025 by kumarlokesh Loading…
MINOR : Handle error for client telemetry push ci-approved clients core Kafka Broker small Small PRs
#19881 opened Jun 2, 2025 by k-raina Loading…
7
KAFKA-18462: Upgrade RocksDB dependency from 9.7.3 to 10.2.1 build Gradle build or GitHub Actions dependencies Pull requests that update a dependency file small Small PRs streams
#19880 opened Jun 2, 2025 by brandboat Loading…
5
KAFKA-14895: [1/N] Move AddPartitionsToTxnManager files to java core Kafka Broker
#19879 opened Jun 2, 2025 by brandboat Loading…
16
KAFKA-19340: Move DelayedRemoteFetch to the storage module core Kafka Broker KIP-932 Queues for Kafka triage PRs from the community
#19876 opened Jun 2, 2025 by DL1231 • Draft
MINOR: Rename ambiguous method name clients consumer small Small PRs triage PRs from the community
#19875 opened Jun 1, 2025 by hgh1472 Loading…
KAFKA-18995: Add bidirectional replication check connect mirror-maker-2 triage PRs from the community
#19874 opened Jun 1, 2025 by kumarlokesh Loading…
[KAFKA-19328] SharePartitionManagerTest testMultipleConcurrentShareFetches doAnswer chaining needs verification ci-approved core Kafka Broker KIP-932 Queues for Kafka small Small PRs tests Test fixes (including flaky tests)
#19872 opened Jun 1, 2025 by ji-seung-ryu Loading…
2
MINOR: Cleanup Connect Module (2/n) ci-approved connect triage PRs from the community
#19871 opened May 31, 2025 by sjhajharia Loading…
KAFKA-19010: Added JVM argument to default configuration build Gradle build or GitHub Actions small Small PRs triage PRs from the community
#19870 opened May 31, 2025 by kumarlokesh Loading…
MINOR: Cleanup Connect Module (1/n) ci-approved connect mirror-maker-2 triage PRs from the community
#19869 opened May 31, 2025 by sjhajharia Loading…
6
MINOR: Refactor createResponseConfig to avoid collection copy and conversion ci-approved core Kafka Broker small Small PRs
#19867 opened May 30, 2025 by yunchipang Loading…
9
KAFKA-18376: High CPU load when AsyncKafkaConsumer uses a small max poll value ci-approved clients consumer KIP-932 Queues for Kafka
#19865 opened May 30, 2025 by kirktrue • Draft
3
KAFKA-19353: Upgrade note and initial docs for KIP-932 build Gradle build or GitHub Actions ci-approved docs KIP-932 Queues for Kafka
#19863 opened May 30, 2025 by AndrewJSchofield Loading…
30
KAFKA-19325 improve forceComplete() in DelayedOperation core Kafka Broker KIP-932 Queues for Kafka performance storage Pull requests that target the storage module
#19862 opened May 30, 2025 by m1a2st Loading…
11
KAFKA-19048: Minimal movement replica balancing algorithm for reassignment kraft tools triage PRs from the community
#19858 opened May 30, 2025 by pjl1070048431 Loading…
KAFKA-19350 Don't propagate the error caused by CreateTopicPolicy to FatalFaultHandler ci-approved kraft small Small PRs
#19857 opened May 30, 2025 by johnny94 Loading…
1
KAFKA-17747: [7/N] Add integration test for rack aware assignment build Gradle build or GitHub Actions clients consumer
#19856 opened May 30, 2025 by FrankYang0529 Loading…
11
KAFKA-19354: KRaft observer should fetch from leader after rediscovery ci-approved kraft small Small PRs tests Test fixes (including flaky tests)
#19854 opened May 30, 2025 by ahuang98 Loading…
9
MINOR: Remove unused code from storage classes ci-approved small Small PRs storage Pull requests that target the storage module tiered-storage Related to the Tiered Storage feature
#19853 opened May 29, 2025 by wernerdv Loading…
8
MINOR: Cleanup ShareFetchAcknowledgeRequestTest ci-approved core Kafka Broker tests Test fixes (including flaky tests)
#19852 opened May 29, 2025 by sjhajharia Loading…
5
ProTip! Add no:assignee to see everything that’s not assigned.