Skip to content

Pull requests: apache/kafka

New pull request New
444 Open 22,282 Closed
444 Open 22,282 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: Fix broken relative links in docs/ docs triage PRs from the community
#22813 opened Jul 11, 2026 by mingyen066 Collaborator Loading…
KAFKA-18951: Correct topic name in client example docs docs small Small PRs triage PRs from the community
#22812 opened Jul 11, 2026 by gvdutra Loading…
MINOR: Rewrite TransactionMetadataTest from Scala to Java build Gradle build or GitHub Actions core Kafka Broker transactions Transactions and EOS triage PRs from the community
#22811 opened Jul 11, 2026 by m1a2st Collaborator Loading…
Reduce lock contention in ProducerMetadata#add clients performance producer triage PRs from the community
#22810 opened Jul 10, 2026 by eeriee Loading…
KAFKA-20796: Fix num-open-iterators metric for timestamped range queries small Small PRs streams triage PRs from the community
#22809 opened Jul 10, 2026 by dino2895 Loading…
KAFKA-20695: Extend "describe group" to return "task offset" metadata group-coordinator triage PRs from the community
#22808 opened Jul 10, 2026 by gabriellefu Contributor Loading…
KAFKA-20787: Implement KIP-1340: Expose Both Mapped Key and Stream Key in Streams-GlobalKTable Joins ci-approved kip Requires or implements a KIP streams
#22807 opened Jul 10, 2026 by lucliu1108 Contributor Loading…
9
let metered store's readonly override with header aware store streams triage PRs from the community
#22806 opened Jul 10, 2026 by lucliu1108 Contributor • Draft
KAFKA-16517 Do not decode metadata records in the internal kraft partition listener core Kafka Broker kraft triage PRs from the community
#22805 opened Jul 10, 2026 by 0xffff-zhiyan Contributor Loading…
KAFKA-20793: Bump latest production ShareVersion to 2 (SV_2). ci-approved core Kafka Broker KIP-932 Queues for Kafka small Small PRs tools
#22803 opened Jul 10, 2026 by smjn Collaborator Loading…
KAFKA-20771: Enforce max msg bytes in share group DLQ produce path. ci-approved clients core Kafka Broker KIP-932 Queues for Kafka
#22802 opened Jul 10, 2026 by smjn Collaborator Loading…
KAFKA-20705: IQv2 TimestampedWindowKeyWithHeadersQuery for headers-aware window stores (KIP-1356) streams triage PRs from the community
#22799 opened Jul 9, 2026 by Jess668 Contributor • Draft
MINOR: Rename RequestChannelMetrics.apply to get ci-approved core Kafka Broker small Small PRs
#22798 opened Jul 9, 2026 by dino2895 Loading…
5
KAFKA-20777: Make a closed StagedMergeIterator throw InvalidStateStoreException small Small PRs streams triage PRs from the community
#22797 opened Jul 9, 2026 by alanlau28 Contributor Loading…
MINOR: Document temporal collision window in offset-commit protocol docs small Small PRs triage PRs from the community
#22796 opened Jul 9, 2026 by illyar80 Loading…
KAFKA-20650: Share ClientQuotaCallback across broker and controller in combined mode clients core Kafka Broker small Small PRs triage PRs from the community
#22792 opened Jul 9, 2026 by vismaytiwari Loading…
KAFKA-19877: Clarify Deserializer ByteBuffer position/limit contract clients small Small PRs triage PRs from the community
#22791 opened Jul 9, 2026 by vismaytiwari Loading…
KAFKA-20597: Fix prefixScan overflow for prefixes with no upper bound in in-memory state stores clients small Small PRs streams triage PRs from the community
#22789 opened Jul 9, 2026 by edenfunf Loading…
3 tasks
KAFKA-20790: Promote streams assignor API to public module group-coordinator performance triage PRs from the community
#22788 opened Jul 8, 2026 by gabriellefu Contributor Loading…
KAFKA-20772 (1/n): Add DLQ system tests for single-partition share group scenarios ci-approved KIP-932 Queues for Kafka tools
#22786 opened Jul 8, 2026 by sjhajharia Collaborator Loading…
16
KAFKA-20539 Prevent Hot Data Loss on Partition Expansion for Latest Policy clients consumer small Small PRs triage PRs from the community
#22784 opened Jul 8, 2026 by m1a2st Collaborator Loading…
KAFKA-20719: "Streams" group sticky assignor not sticky at startup group-coordinator streams triage PRs from the community
#22783 opened Jul 7, 2026 by gabriellefu Contributor Loading…
MINOR: Replace deprecated TopologyTestDriver constructor in TestTopicsTest ci-approved small Small PRs streams tests Test fixes (including flaky tests)
#22782 opened Jul 7, 2026 by JiayaoS Contributor Loading…
1
MINOR: Move Log4jControllerRegistration to server module ci-approved core Kafka Broker small Small PRs
#22779 opened Jul 7, 2026 by majialoong Contributor Loading…
6
KAFKA-20782: IQ bug under streams protocol clients consumer small Small PRs streams tests Test fixes (including flaky tests)
#22778 opened Jul 7, 2026 by UladzislauBlok Contributor Loading…
5
ProTip! Type g i on any issue or pull request to go back to the issue listing page.