Skip to content

Pull requests: apache/kafka

New pull request New
228 Open 20,632 Closed
228 Open 20,632 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: Remove early access warning for streams rebalance protocol group-coordinator small Small PRs triage PRs from the community
#20873 opened Nov 13, 2025 by mingyen066 Loading…
KAFKA-19884: Add tests to ensure Consumer.close() timeouts work as documented clients tests Test fixes (including flaky tests) triage PRs from the community
#20872 opened Nov 13, 2025 by kirktrue Loading…
[WIP] Draft proposal for adding retries to timed out KS EOS commit requests small Small PRs streams
#20871 opened Nov 13, 2025 by bbejeck • Draft
MINOR: make description more clear for group.protocol ci-approved clients consumer small Small PRs
#20870 opened Nov 12, 2025 by joel-hamill Loading…
3
KIP-1228: Add Transaction Version to request builder [2/3] ci-approved clients core Kafka Broker
#20868 opened Nov 12, 2025 by rreddy-22 Loading…
8
MINOR: Docs for kafka-share-groups.sh --reset-offsets docs KIP-932 Queues for Kafka small Small PRs
#20867 opened Nov 12, 2025 by AndrewJSchofield Loading…
7
KAFKA-19761 Gradle Shadow plugin version upgrade: 8.3.9 -->> 9.2.2 build Gradle build or GitHub Actions small Small PRs
#20866 opened Nov 12, 2025 by dejan2609 Loading…
2
MINOR: Fix topic option description in kafka-topics.sh ci-approved small Small PRs tools triage PRs from the community
#20865 opened Nov 12, 2025 by DL1231 Loading…
11
[Draft] KAFKA-19393: Consolidate consumer assignment state views. clients consumer triage PRs from the community
#20863 opened Nov 12, 2025 by chickenchickenlove • Draft
KAFKA-19755 Move KRaftClusterTest from core module to server module [2/4] ci-approved core Kafka Broker tests Test fixes (including flaky tests)
#20861 opened Nov 12, 2025 by DL1231 Loading…
3
KAFKA-19850: KRaft voter auto join will add a removed voter immediately ci-approved core Kafka Broker kraft
#20859 opened Nov 11, 2025 by TaiJuWu • Draft
11
KAFKA-19683: More test replacements [6/N] ci-approved streams tests Test fixes (including flaky tests)
#20858 opened Nov 11, 2025 by shashankhs11 Loading…
@lucasbru
8
KAFKA-19767 - Send Share-Fetch one-node at a time for record_limit mode ci-approved clients consumer KIP-932 Queues for Kafka
#20855 opened Nov 10, 2025 by ShivsundarR Loading…
MINOR: Clean up RemoteLogManagerTest.testCopyQuota small Small PRs storage Pull requests that target the storage module tests Test fixes (including flaky tests) tiered-storage Related to the Tiered Storage feature
#20853 opened Nov 10, 2025 by UladzislauBlok Loading…
2
KAFKA-19800-2: Created an implementation class NetworkPartitionMetadataClient for PartitionMetadataClient ci-approved core Kafka Broker group-coordinator KIP-932 Queues for Kafka
#20852 opened Nov 10, 2025 by chirag-wadhwa5 Loading…
39
KAFKA-19874: Fix resource leak in TopicBasedRemoteLogMetadataManager. ci-approved small Small PRs storage Pull requests that target the storage module tiered-storage Related to the Tiered Storage feature triage PRs from the community
#20849 opened Nov 10, 2025 by lightzhao Loading…
KAFKA-19519: Introduce group.coordinator.append.max.buffer.size config ci-approved clients core Kafka Broker group-coordinator KIP-932 Queues for Kafka
#20847 opened Nov 7, 2025 by DL1231 Loading…
9
KAFKA-19875 Duplicated topic config prevents broker start clients connect core Kafka Broker tests Test fixes (including flaky tests) tools
#20844 opened Nov 7, 2025 by m1a2st Loading…
6
KAFKA-19869: Mark streams groups records and APIs stable clients consumer core Kafka Broker group-coordinator streams
#20841 opened Nov 6, 2025 by lucasbru Loading…
7
KAFKA-17541:[2/2] Improve handling of delivery count ci-approved core Kafka Broker KIP-932 Queues for Kafka
#20837 opened Nov 6, 2025 by DL1231 Loading…
22
KAFKA-19853: commit open tasks before handling assignment ci-approved small Small PRs streams
#20833 opened Nov 5, 2025 by coltmcnealy-lh Loading…
14
MINOR: Add Gradle task to verify ASF license header in JSON files build Gradle build or GitHub Actions small Small PRs
#20825 opened Nov 4, 2025 by mingyen066 Loading…
2
KAFKA-19858: Move the __remote_log_metadata to internal clients core Kafka Broker kip Requires or implements a KIP small Small PRs storage Pull requests that target the storage module tiered-storage Related to the Tiered Storage feature
#20822 opened Nov 4, 2025 by jiafu1115 Loading…
4
MINOR: Add missing log4j2.yaml file for some modules core Kafka Broker group-coordinator KIP-932 Queues for Kafka storage Pull requests that target the storage module tests Test fixes (including flaky tests) tools transactions Transactions and EOS
#20821 opened Nov 4, 2025 by TaiJuWu Loading…
7
KAFKA-19858: Set default min.insync.replicas=2 for __remote_log_metadata topic to prevent data loss (KIP-1235) ci-approved small Small PRs storage Pull requests that target the storage module tiered-storage Related to the Tiered Storage feature
#20811 opened Nov 3, 2025 by jiafu1115 Loading…
16
ProTip! Exclude everything labeled bug with -label:bug.