Skip to content

Pull requests: apache/kafka

New pull request New
253 Open 19,650 Closed
253 Open 19,650 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-19376: Throw an error message if any unsupported feature is used with KIP-1071 streams
#19908 opened Jun 5, 2025 by lucasbru Loading…
3
KAFKA-19370: Create JMH benchmark for share group assignor ci-approved KIP-932 Queues for Kafka performance
#19907 opened Jun 5, 2025 by AndrewJSchofield Loading…
KAFKA-19306: Migrate LogCompactionTester to tools module build Gradle build or GitHub Actions core Kafka Broker tests Test fixes (including flaky tests) tools triage PRs from the community
#19905 opened Jun 4, 2025 by yunchipang • Draft
KAFKA-18961: Time-based refresh for server-side RE2J regex ci-approved core Kafka Broker
#19904 opened Jun 4, 2025 by dongnuo123 Loading…
6
KAFKA-18202: Add rejection for non-zero sequences in TV2 (KIP-890) ci-approved small Small PRs storage Pull requests that target the storage module
#19902 opened Jun 4, 2025 by rreddy-22 Loading…
4
KAFKA-19369: Add group.share.assignors config and integration test build Gradle build or GitHub Actions ci-approved clients connect consumer KIP-932 Queues for Kafka
#19900 opened Jun 4, 2025 by FrankYang0529 Loading…
2
When a broker restarts, it should not attempt to create the __remote_log_metadata topic if it already exists. small Small PRs storage Pull requests that target the storage module tiered-storage Related to the Tiered Storage feature
#19899 opened Jun 4, 2025 by jiafu1115 Loading…
2
MINOR: Safe update dependencies build Gradle build or GitHub Actions ci-approved dependencies Pull requests that update a dependency file small Small PRs triage PRs from the community
#19897 opened Jun 4, 2025 by Mirai1129 Loading…
5
KAFKA-19244: Add support for kafka-streams-groups.sh options (delete offsets) [4/N] tools triage PRs from the community
#19895 opened Jun 4, 2025 by aliehsaeedii Loading…
3
KAFKA-19244: Add support for kafka-streams-groups.sh options (delete internal topics) [3/N] tools triage PRs from the community
#19893 opened Jun 4, 2025 by aliehsaeedii Loading…
9
KAFKA-18486: Update activeProducerState wih KRaft mechanism in ReplicaManagerTest ci-approved core Kafka Broker small Small PRs tests Test fixes (including flaky tests) triage PRs from the community
#19890 opened Jun 3, 2025 by YutaLin Loading…
KAFKA-18913: Start state updater in task manager small Small PRs streams
#19889 opened Jun 3, 2025 by janchilling Loading…
12
MINOR: Refactor brokerContactTimesMs and brokerRegistrationStates to use Long and Integer ci-approved kraft small Small PRs
#19888 opened Jun 3, 2025 by apalan60 Loading…
13
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…
7
KAFKA-15283:[2/2] Client support for OffsetFetch with topic ID ci-approved clients consumer small Small PRs
#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
#19884 opened Jun 3, 2025 by YutaLin Loading…
3
KAFKA-18486: Update testExceptionWhenUnverifiedTransactionHasMultipleProducerIds ci-approved core Kafka Broker small Small PRs tests Test fixes (including flaky tests)
#19883 opened Jun 3, 2025 by jingjia88 Loading…
6
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…
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…
7
KAFKA-14895: [1/N] Move AddPartitionsToTxnManager files to java core Kafka Broker
#19879 opened Jun 2, 2025 by brandboat Loading…
19
KAFKA-19340: Move DelayedRemoteFetch to the storage module ci-approved core Kafka Broker KIP-932 Queues for Kafka triage PRs from the community
#19876 opened Jun 2, 2025 by DL1231 Loading…
1
MINOR: Rename ambiguous method name clients consumer small Small PRs
#19875 opened Jun 1, 2025 by hgh1472 Loading…
4
KAFKA-18995: Add bidirectional replication check connect mirror-maker-2 triage PRs from the community
#19874 opened Jun 1, 2025 by kumarlokesh Loading…
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…
ProTip! Type g p on any issue or pull request to go back to the pull request listing page.