Skip to content

Pull requests: apache/kafka

New pull request New
330 Open 21,408 Closed
330 Open 21,408 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: add docs redirect docs small Small PRs streams
#21752 opened Mar 13, 2026 by mjsax Loading…
KAFKA-20287 : Fix CF handle leaks streams triage PRs from the community
#21751 opened Mar 13, 2026 by muralibasani Loading…
6
KAFKA-19713: Persist Position into offsets CF small Small PRs streams triage PRs from the community
#21750 opened Mar 13, 2026 by eduwercamacaro • Draft
KAFKA-20158: Parameterize session store unit tests to run with headers-aware store format streams
#21749 opened Mar 13, 2026 by bbejeck Loading…
KAFKA-20301: Upgrade downgrade integration tests for session store with headers streams
#21748 opened Mar 13, 2026 by bbejeck Loading…
2
fix: architecture detection for Kafka heap options small Small PRs triage PRs from the community
#21747 opened Mar 13, 2026 by yunnysunny Loading…
1
KAFKA-20308: Update TopologyTestDriver to support for headers-aware stores streams triage PRs from the community
#21745 opened Mar 13, 2026 by aliehsaeedii Loading…
KAFKA-20307: Add Interactive Queries (IQv1) support for headers-aware stores streams triage PRs from the community
#21744 opened Mar 13, 2026 by aliehsaeedii Loading…
KAFKA-20304: Implement all required ReadOnly*Facade classes for headers stores streams triage PRs from the community
#21743 opened Mar 13, 2026 by aliehsaeedii Loading…
1
KAFKA-20302: Receive buffers allocated from MemoryPool may not be released if request is invalid clients core Kafka Broker triage PRs from the community
#21740 opened Mar 13, 2026 by edoardocomar Loading…
3
KAFKA-20257: GlobalStateManagerImpl delegates offset tracking to stores streams triage PRs from the community
#21739 opened Mar 12, 2026 by nicktelford Loading…
3
KAFKA-19712: ProcessorStateManager delegates offset tracking to stores streams triage PRs from the community
#21738 opened Mar 12, 2026 by nicktelford Loading…
1
KAFKA-18652: Add task.offset.interval.ms config clients consumer core Kafka Broker group-coordinator KIP-1071 PRs related to KIP-1071 streams tools
#21737 opened Mar 12, 2026 by mjsax Loading…
5
KAFKA-20132: Fix header-based key deserialization in MeteredTimestampedKeyValueStoreWithHeaders iterator methods kip Requires or implements a KIP streams
#21736 opened Mar 12, 2026 by frankvicky Loading…
KAFKA-15370: Support Participation in 2PC (KIP-939) (K/N) clients core Kafka Broker producer transactions Transactions and EOS
#21735 opened Mar 12, 2026 by artemlivshits Loading…
17
KAFKA-20158: Fix header-based key deserialization in MeteredSessionStoreWithHeaders iterator methods streams
#21734 opened Mar 12, 2026 by bbejeck Loading…
KAFKA-20117: Improve ClusterControlManager error message ci-approved
#21731 opened Mar 12, 2026 by Rancho-7 Loading…
KAFKA-20292 [1/N]: Handle membership changes during offloaded assignments group-coordinator performance triage PRs from the community
#21728 opened Mar 12, 2026 by squah-confluent Loading…
KAFKA-20292 [2/N]: Handle membership changes during offloaded streams assignments group-coordinator triage PRs from the community
#21727 opened Mar 12, 2026 by squah-confluent Loading…
MINOR: replace mkMap/mkEntry with Map.of/Map.entry in clients module clients consumer
#21726 opened Mar 12, 2026 by DL1231 Loading…
8
KAFKA-20116: Send client.rack via StreamsHeartbeatRequest clients consumer core Kafka Broker group-coordinator KIP-1071 PRs related to KIP-1071 streams
#21725 opened Mar 12, 2026 by mjsax Loading…
3
MINOR: improve StreamsConfig client-tags verification streams
#21724 opened Mar 12, 2026 by mjsax Loading…
4
KAFKA-20291 [3/3]: Implement assignment batching for streams groups ci-approved core Kafka Broker group-coordinator streams
#21722 opened Mar 12, 2026 by squah-confluent Loading…
4
KAFKA-20291 [2/3]: Implement assignment batching for share groups ci-approved core Kafka Broker group-coordinator
#21721 opened Mar 12, 2026 by squah-confluent Loading…
1
KAFKA-20291 [1/3]: Implement assignment batching for consumer groups ci-approved core Kafka Broker group-coordinator
#21720 opened Mar 12, 2026 by squah-confluent Loading…
9
ProTip! Add no:assignee to see everything that’s not assigned.