Skip to content

Pull requests: apache/kafka

New pull request New
423 Open 22,152 Closed
423 Open 22,152 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: Simplify AlterPartitionManager request building and tests ci-approved core Kafka Broker small Small PRs triage PRs from the community
#22589 opened Jun 16, 2026 by joshua2519 Contributor Loading…
KAFKA-20693: fix npe in abstract herder when no config value connect small Small PRs triage PRs from the community
#22588 opened Jun 16, 2026 by gaetancollaud Loading…
KAFKA-14405: Log a warning when users attempt to set a config controlled by Streams small Small PRs streams
#22586 opened Jun 15, 2026 by suzhiking Contributor Loading…
2
KAFKA-19200: Recover pre-allocated never-written time index on startup storage Pull requests that target the storage module tiered-storage Related to the Tiered Storage feature triage PRs from the community
#22585 opened Jun 15, 2026 by sidharthdaga Loading…
MINOR: Cleanups following KAFKA-20637 core Kafka Broker small Small PRs
#22584 opened Jun 15, 2026 by mimaison Member Loading…
(WIP-PoC) KIP-1356: IQv2 TimestampedKeyWithHeadersQuery for headers-aware state stores streams triage PRs from the community
#22583 opened Jun 15, 2026 by Jess668 Contributor • Draft
MINOR: Migrate SaslClientsWithInvalidCredentialsTest to ClusterInstance build Gradle build or GitHub Actions ci-approved tools triage PRs from the community
#22582 opened Jun 15, 2026 by majialoong Contributor Loading…
KAFKA-20662: Throw INCONSISTENT_GROUP_PROTOCOL for malformed request during online migration ci-approved group-coordinator small Small PRs
#22580 opened Jun 15, 2026 by dongnuo123 Contributor Loading…
1
MINOR: Remove unnecessary Hamcrest dependency from tools module build Gradle build or GitHub Actions ci-approved small Small PRs streams
#22579 opened Jun 15, 2026 by Russole Contributor • Draft
4
KAFKA-20377: Add to pass additional Docker build arguments in the system tests small Small PRs tests Test fixes (including flaky tests)
#22578 opened Jun 15, 2026 by see-quick Contributor Loading…
KAFKA-20692: Add unit tests for ToolsUtils tests Test fixes (including flaky tests) tools triage PRs from the community
#22577 opened Jun 15, 2026 by Dpk376 Loading…
MINOR: Move transaction coordinator leaf classes from Scala to Java core Kafka Broker transactions Transactions and EOS
#22576 opened Jun 15, 2026 by sjhajharia Collaborator Loading…
5
KAFKA-20677: Enhance test coverage of testCannotSendToInternalTopic clients tests Test fixes (including flaky tests) triage PRs from the community
#22575 opened Jun 15, 2026 by aravind-kvs Loading…
3
KAFKA-8035: Add lambda and anonymous class tests for KStream API generics streams tests Test fixes (including flaky tests) triage PRs from the community
#22574 opened Jun 15, 2026 by Dpk376 Loading…
KAFKA-13716: Add unit tests for DeleteRecordsCommand ci-approved small Small PRs tests Test fixes (including flaky tests) tools
#22573 opened Jun 15, 2026 by Dpk376 Loading…
KAFKA-20197: Headers aware StreamPartitioner streams
#22570 opened Jun 14, 2026 by UladzislauBlok Contributor • Draft
1
KAFKA-19919: Avoid reverse DNS for built-in SASL servers clients triage PRs from the community
#22569 opened Jun 14, 2026 by lh0156 Loading…
1
updated request metrics documentation to apply for all APIs docs small Small PRs triage PRs from the community
#22567 opened Jun 13, 2026 by Samrev Loading…
MINOR: Fix missing parenthesis in under-min-ISR trace log ci-approved clients consumer core Kafka Broker producer small Small PRs
#22565 opened Jun 13, 2026 by coderbruis Loading…
5
KAFKA-20553 Eliminate the dependencies on sourceSets.test.output for core module build Gradle build or GitHub Actions ci-approved core Kafka Broker
#22564 opened Jun 13, 2026 by majialoong Contributor Loading…
4
MINOR: Followup Add KIP-1284 into streams upgrade document ci-approved docs small Small PRs triage PRs from the community
#22563 opened Jun 13, 2026 by m1a2st Collaborator Loading…
KAFKA-19602: fix(streams): propagate state store names from KTable.transformValues to downstream KTable join small Small PRs streams
#22562 opened Jun 13, 2026 by wilmerdooley Loading…
4
KAFKA-20169: Add ducktape test code for Streams Rebalance Protocol. ci-approved clients consumer streams triage PRs from the community
#22561 opened Jun 13, 2026 by chickenchickenlove Contributor Loading…
@lucasbru
3
KAFKA-19465: feat(connect): add value.type config to InsertHeader SMT connect triage PRs from the community
#22560 opened Jun 13, 2026 by wilmerdooley Loading…
KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Client Side. ci-approved clients consumer streams triage PRs from the community
#22559 opened Jun 13, 2026 by chickenchickenlove Contributor Loading…
@lucasbru
6
ProTip! Filter pull requests by the default branch with base:trunk.