Skip to content

Pull requests: apache/kafka

New pull request New
329 Open 21,393 Closed
329 Open 21,393 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

KAFKA-20132: Fix header-based key deserialization in MeteredTimestampedKeyValueStoreWithHeaders iterator methods kip Requires or implements a KIP streams triage PRs from the community
#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 triage PRs from the community
#21735 opened Mar 12, 2026 by artemlivshits Loading…
KAFKA-20158: Fix header-based key deserialization in MeteredSessionStoreWithHeaders iterator methods streams
#21734 opened Mar 12, 2026 by bbejeck Loading…
MINOR: Flaky testDynamicPartitionMaxRecordLocks clients small Small PRs tests Test fixes (including flaky tests)
#21733 opened Mar 12, 2026 by AndrewJSchofield Loading…
KAFKA-20117: Improve ClusterControlManager error message ci-approved
#21731 opened Mar 12, 2026 by Rancho-7 Loading…
KAFKA-20300: Add broker configs for assignment batching and offload ci-approved core Kafka Broker group-coordinator
#21730 opened Mar 12, 2026 by squah-confluent Loading…
7
MINOR: Fix log messages for epoch comparison in ReplicationControlManager kraft small Small PRs triage PRs from the community
#21729 opened Mar 12, 2026 by giuseppelillo 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 triage PRs from the community
#21726 opened Mar 12, 2026 by DL1231 Loading…
2
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…
MINOR: improve StreamsConfig client-tags verification streams
#21724 opened Mar 12, 2026 by mjsax Loading…
KAFKA-20291 [3/3]: Implement assignment batching for streams groups ci-approved group-coordinator
#21722 opened Mar 12, 2026 by squah-confluent Loading…
1
KAFKA-20291 [2/3]: Implement assignment batching for share groups ci-approved group-coordinator
#21721 opened Mar 12, 2026 by squah-confluent Loading…
1
KAFKA-20291 [1/3]: Implement assignment batching for consumer groups ci-approved group-coordinator
#21720 opened Mar 12, 2026 by squah-confluent Loading…
2
KAFKA-20297 Remove MappedIterator and test ci-approved clients
#21719 opened Mar 12, 2026 by gongxuanzhang Loading…
1
KAFKA-20199: Use NodeId selector metric tag on controller-only KRaft nodes core Kafka Broker small Small PRs triage PRs from the community
#21718 opened Mar 12, 2026 by nileshkumar3 Loading…
3
KAFKA-19697 NPE Cannot invoke org.apache.kafka.connect.runtime.ConnectMetrics$MetricGroup.close() connect small Small PRs
#21717 opened Mar 12, 2026 by m1a2st Loading…
1
KAFKA-19906: Guard against null metric key in StreamsMetricsImpl small Small PRs streams
#21716 opened Mar 12, 2026 by mvanhorn Loading…
2 tasks done
2
KAFKA-20237: Re-enqueue InitProducerId request after authentication failure clients producer small Small PRs triage PRs from the community
#21715 opened Mar 12, 2026 by mvanhorn Loading…
KAFKA-20253: Fix high CPU loop after failed re-authentication ci-approved clients consumer small Small PRs triage PRs from the community
#21714 opened Mar 12, 2026 by mvanhorn Loading…
MINOR: Share group tidying clients consumer KIP-932 Queues for Kafka
#21711 opened Mar 11, 2026 by AndrewJSchofield Loading…
KAFKA-20261: Upgrade path for plain window store to headers store kip Requires or implements a KIP streams
#21710 opened Mar 11, 2026 by frankvicky Loading…
2
fix(docs): clean typos and grammar across quickstart, connect, streams, and MirrorMaker docs docs small Small PRs triage PRs from the community
#21709 opened Mar 11, 2026 by Zhang-Charlie Loading…
MINOR: Remove temporary internal config group.share.enable clients core Kafka Broker group-coordinator KIP-932 Queues for Kafka
#21708 opened Mar 11, 2026 by sjhajharia Loading…
10
ProTip! Type g i on any issue or pull request to go back to the issue listing page.