Skip to content

Pull requests: apache/kafka

New pull request New
424 Open 22,144 Closed
424 Open 22,144 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: 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-20694: Fix share read leader epoch sentinel KIP-932 Queues for Kafka small Small PRs triage PRs from the community
#22581 opened Jun 15, 2026 by Shekharrajak Contributor Loading…
1
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…
MINOR: Remove unnecessary Hamcrest dependency from tools module build Gradle build or GitHub Actions ci-approved small Small PRs streams triage PRs from the community
#22579 opened Jun 15, 2026 by Russole Loading…
1
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 triage PRs from the community
#22576 opened Jun 15, 2026 by sjhajharia Collaborator Loading…
4
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…
2
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-20691: PersisterStateBatchCombiner.combineStateBatches() with an event-driven sweep-line ci-approved KIP-932 Queues for Kafka
#22572 opened Jun 14, 2026 by Shekharrajak Contributor Loading…
8
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 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. clients consumer streams triage PRs from the community
#22561 opened Jun 13, 2026 by chickenchickenlove Contributor Loading…
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. clients consumer streams triage PRs from the community
#22559 opened Jun 13, 2026 by chickenchickenlove Contributor Loading…
KAFKA-19902: fix(consumer): use latest leader epoch when committing offsets clients consumer small Small PRs triage PRs from the community
#22558 opened Jun 13, 2026 by wilmerdooley Loading…
1 task done
KAFKA-20623: DeleteGroups extension for streams group topology description plugin (3/3) core Kafka Broker group-coordinator triage PRs from the community
#22554 opened Jun 12, 2026 by frankvicky Contributor Loading…
@lucasbru
17
KAFKA-19753: Fix duplicated topic metrics in FetchMetricsManager for topic names containing dots clients consumer triage PRs from the community
#22553 opened Jun 12, 2026 by wilmerdooley Loading…
KAFKA-20623: Update RPC for streams group topology description plugin (2/3) core Kafka Broker group-coordinator triage PRs from the community
#22552 opened Jun 12, 2026 by frankvicky Contributor Loading…
@lucasbru
15
ProTip! Find all pull requests that aren't related to any open issues with -linked:issue.