Skip to content

Pull requests: apache/kafka

New pull request New
337 Open 21,667 Closed
337 Open 21,667 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

[WIP] KAFKA-20426: Using both group.id and assign() causes a busy loop in AsyncKafkaConsumer clients consumer small Small PRs
#22018 opened Apr 10, 2026 by brandboat Member Loading…
1
MINOR: Split up ShareConsumerTest clients tests Test fixes (including flaky tests)
#22017 opened Apr 9, 2026 by AndrewJSchofield Member Loading…
1
KAFKA-19839: Fix NoSuchFieldError for zstd compression in native image docker Official Docker image small Small PRs triage PRs from the community
#22016 opened Apr 9, 2026 by sstremler Contributor Loading…
1
KAFKA-20431: ConsumerGroupDescribe API does not return partitions being revoked core Kafka Broker group-coordinator
#22015 opened Apr 9, 2026 by dajac Member Loading…
15
MINOR: Fix tool package in kafka-dump-log.bat small Small PRs
#22014 opened Apr 9, 2026 by mimaison Member Loading…
KAFKA-14588: Move ConfigCommand to tools module clients core Kafka Broker tools
#22013 opened Apr 9, 2026 by mimaison Member Loading…
2
KAFKA-20182: Upgrade gradle to 9.4.1 and spotless to 8.3.0 build Gradle build or GitHub Actions small Small PRs
#22012 opened Apr 9, 2026 by mingyen066 Collaborator Loading…
4
KAFKA-20428: Fix unsubscribe failure with assignment updates clients consumer
#22011 opened Apr 9, 2026 by lianetm Member Loading…
6
MINOR : formatting fix on UpdateRaftVoterRequest class declaration ci-approved clients small Small PRs triage PRs from the community
#22010 opened Apr 9, 2026 by ppatierno Contributor Loading…
KAFKA-20246: Add clusterId and nodeId to ApiVersionsRequest (2/N) clients core Kafka Broker small Small PRs
#22007 opened Apr 9, 2026 by AndrewJSchofield Member • Draft
KAFKA-20198: Fix StickyTaskAssignor capacity calculation to use proportional instance limit small Small PRs streams triage PRs from the community
#22006 opened Apr 9, 2026 by ChoMinGi Loading…
KAFKA-20422: Add DSL integration tests for header stores with explicit suppliers ci-approved streams tests Test fixes (including flaky tests)
#22002 opened Apr 8, 2026 by aliehsaeedii Contributor Loading…
2
KAFKA-20391: Improve types returned by the Connect REST API connect small Small PRs triage PRs from the community
#22001 opened Apr 8, 2026 by gomudayya Contributor Loading…
KAFKA-19701 : Marking testDescribeStreamsGroupWithShortTimeout as flaky build Gradle build or GitHub Actions ci-approved small Small PRs tests Test fixes (including flaky tests) tools
#22000 opened Apr 8, 2026 by muralibasani Contributor Loading…
5
KAFKA-20417: Add KIP-1035 self-managed offset lifecycle integration tests streams tests Test fixes (including flaky tests)
#21999 opened Apr 8, 2026 by bbejeck Member Loading…
KAFKA-20417: Add KIP-1035 self-managed offset recovery integration tests streams tests Test fixes (including flaky tests)
#21998 opened Apr 8, 2026 by bbejeck Member Loading…
11
KAFKA-20155: Implement lazy header deserialization for state stores streams
#21996 opened Apr 8, 2026 by Shekharrajak Loading…
16
KAFKA-20399: Implement VersionedKeyValueStoreWithHeaders streams
#21995 opened Apr 8, 2026 by Shekharrajak • Draft
5
KAFKA-20397 Avoid blocking on fetchBuffer when metadata error is pending clients consumer small Small PRs
#21991 opened Apr 8, 2026 by nileshkumar3 Contributor Loading…
8
MINOR: Flaky test fixes ci-approved clients consumer small Small PRs tools
#21986 opened Apr 7, 2026 by AndrewJSchofield Member Loading…
5
MINOR: Fixed documentation on formatting new brokers docs small Small PRs
#21981 opened Apr 7, 2026 by ppatierno Contributor Loading…
10
KAFKA-20388: Move LogConfigTest from core to storage ci-approved core Kafka Broker storage Pull requests that target the storage module tests Test fixes (including flaky tests)
#21980 opened Apr 7, 2026 by see-quick Contributor Loading…
6
KAFKA-20410: Add DLQ configuration parameters for Share Groups (KIP-1191) ci-approved clients core Kafka Broker group-coordinator KIP-932 Queues for Kafka
#21979 opened Apr 7, 2026 by sjhajharia Collaborator Loading…
2
KAFKA-20389: Filter internal keys from connector plugin config REST response connect small Small PRs
#21976 opened Apr 7, 2026 by nileshkumar3 Contributor Loading…
5
KAFKA-18309: Change log.segment.bytes config type from INT to LONG core Kafka Broker small Small PRs storage Pull requests that target the storage module
#21975 opened Apr 6, 2026 by acgtun Loading…
3
ProTip! What’s not been updated in a month: updated:<2026-03-09.