Skip to content

Pull requests: apache/kafka

New pull request New
265 Open 20,120 Closed
265 Open 20,120 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

Revert "KAFKA-13722: remove usage of old ProcessorContext (#18292)"
#20398 opened Aug 22, 2025 by mjsax Loading…
Implementing KIP-977 clients core Kafka Broker storage Pull requests that target the storage module
#20397 opened Aug 22, 2025 by danoSF • Draft
9
KAFKA-19616: Add compression type and level support to LogCompactionTester ci-approved tools triage PRs from the community
#20396 opened Aug 22, 2025 by yunchipang Loading…
1
KAFKA-19632: Handle overlap batch on partition re-assignment ci-approved core Kafka Broker KIP-932 Queues for Kafka
#20395 opened Aug 21, 2025 by apoorvmittal10 Loading…
2
MINOR: Cleanup Connect Module (5/n) ci-approved connect triage PRs from the community
#20393 opened Aug 21, 2025 by sjhajharia Loading…
KAFKA-18913: Remove state.updater.enabled flag from StreamThread and … streams triage PRs from the community
#20392 opened Aug 21, 2025 by janchilling Loading…
1
KAFKA-19625: Consistency of command-line arguments for verifiable producer/consumer small Small PRs tools triage PRs from the community
#20390 opened Aug 21, 2025 by JimmyWang6 Loading…
MINOR: Cleanup Connect Module (4/n) ci-approved connect triage PRs from the community
#20389 opened Aug 21, 2025 by sjhajharia Loading…
KAFKA-19617: ConsumerPerformance#ConsumerPerfRebListener get corrupted value when the number of partitions is increased ci-approved small Small PRs tools triage PRs from the community
#20388 opened Aug 21, 2025 by DL1231 Loading…
Feature/grade docs small Small PRs triage PRs from the community
#20387 opened Aug 20, 2025 by Ashraf-Sakib Loading…
Add KafkaTopicCalculator feature docs small Small PRs triage PRs from the community
#20386 opened Aug 20, 2025 by Ashraf-Sakib Loading…
KAFKA-19624: Improving consistency of command-line arguments for consumer performance tests ci-approved tools
#20385 opened Aug 20, 2025 by aheev Loading…
1
POC: conditional creation of internal topics in Kafka Connect connect small Small PRs triage PRs from the community
#20384 opened Aug 20, 2025 by anton-liauchuk • Draft
1
KAFKA-19620: Move AutoTopicCreationManager to server module core Kafka Broker performance
#20383 opened Aug 20, 2025 by brandboat Loading…
3
KAFKA-18913: Consider removing state-updater feature flag - 2 small Small PRs streams
#20382 opened Aug 20, 2025 by shashankhs11 • Draft
3 tasks
4
KAFKA-17103: MockClient tight loops when no metadata is present in KafkaProducerTest ci-approved clients producer tests Test fixes (including flaky tests)
#20381 opened Aug 20, 2025 by jack2012aa Loading…
7
MINOR: Update on fixing tag description missing in javadoc small Small PRs storage Pull requests that target the storage module triage PRs from the community
#20380 opened Aug 20, 2025 by keemsisi Loading…
KAFKA-18913: Consider removing state-updater feature flag ci-approved small Small PRs streams
#20378 opened Aug 19, 2025 by shashankhs11 Loading…
2
KAFKA-18447 Support SASL_SSL protocol with java.security.auth.login.config build Gradle build or GitHub Actions
#20376 opened Aug 19, 2025 by m1a2st Loading…
1
MINOR: describeTopics should pass the timeout to the describeCluster call ci-approved clients small Small PRs
#20375 opened Aug 19, 2025 by jim0987795064 Loading…
2
Revert "KAFKA-18681: Created GetReplicaLogInfo RPCs (#19664)" clients core Kafka Broker triage PRs from the community
#20371 opened Aug 18, 2025 by josefk31 Loading…
MINOR: update TransactionLog#readTxnRecordValue to initialize TransactionMetadata with non-empty topic partitions ci-approved core Kafka Broker small Small PRs transactions Transactions and EOS
#20370 opened Aug 18, 2025 by FrankYang0529 Loading…
10
KAFKA-19613: Expose CorruptRecordException for consumer ci-approved clients consumer small Small PRs
#20369 opened Aug 18, 2025 by UladzislauBlok Loading…
2
MINOR: Refactor snapshottableSize method for better readability and simplicity core Kafka Broker small Small PRs triage PRs from the community
#20368 opened Aug 18, 2025 by chanbinme Loading…
KIP-780: Support fine-grained compression options clients core Kafka Broker performance producer storage Pull requests that target the storage module triage PRs from the community
#20367 opened Aug 18, 2025 by see-quick Loading…
ProTip! Adding no:label will show everything without a label.