Skip to content

Pull requests: apache/kafka

New pull request New
Clear current search query, filters, and sorts
257 Open 19,010 Closed
257 Open 19,010 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
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
� 👎 😄 🎉 😕 �� 🚀 👀

Pull requests list

KAFKA-18826: Add global thread metrics streams
#18953 opened Feb 18, 2025 by bbejeck Loading… updated Mar 24, 2025
3 tasks
20
KAFKA-19032: Remove TestInfoUtils.TestWithParameterizedQuorumAndGroupProtocolNames core Kafka Broker storage Pull requests that target the storage module tests Test fixes (including flaky tests) tools
#19270 opened Mar 24, 2025 by FrankYang0529 Loading… updated Mar 24, 2025
KAFKA-18888: Add KIP-877 support to Authorizer clients core Kafka Broker kraft performance
#19050 opened Feb 27, 2025 by mimaison Loading… updated Mar 24, 2025
KAFKA-16729: Support isolation level for share consumer ci-approved clients consumer core Kafka Broker KIP-932 Queues for Kafka
#19261 opened Mar 21, 2025 by adixitconfluent Loading… updated Mar 24, 2025
[WIP]KAFKA-18477 remove usage of OffsetForLeaderEpochRequest in AbstractFetcherThread ci-approved core Kafka Broker triage PRs from the community
#18489 opened Jan 11, 2025 by m1a2st Loading… updated Mar 24, 2025
3 tasks
8
KAFKA-18613: Add StreamsGroupHeartbeat handler in the group coordinator core Kafka Broker KIP-1071 PRs related to KIP-1071 streams
#19114 opened Mar 5, 2025 by lucasbru Loading… updated Mar 24, 2025
89
KAFKA-18736: Handle errors in the Streams group heartbeat request manager clients consumer KIP-1071 PRs related to KIP-1071 streams
#19230 opened Mar 18, 2025 by cadonna Loading… updated Mar 24, 2025
9
KAFKA-18736: Add pollOnClose() and maximumTimeToWait() clients consumer KIP-1071 PRs related to KIP-1071 streams
#19233 opened Mar 18, 2025 by cadonna Loading… updated Mar 24, 2025
2
KAFKA-14486: Move LogCleanerManager to storage module build Gradle build or GitHub Actions ci-approved core Kafka Broker storage Pull requests that target the storage module
#19216 opened Mar 16, 2025 by wernerdv Loading… updated Mar 24, 2025
43
KAFKA-6416: Helm chart for deploying Kafka to Kubernetes docker Official Docker image kip Requires or implements a KIP
#19249 opened Mar 19, 2025 by askew • Draft updated Mar 24, 2025
2
KAFKA-18576: Convert ConfigType to Enum ci-approved core Kafka Broker tools
#18711 opened Jan 27, 2025 by frankvicky Loading… updated Mar 24, 2025
3 tasks
18
Kafka-16505: Adding dead letter queue in Kafka Streams streams
#17942 opened Nov 25, 2024 by Dabz Loading… updated Mar 24, 2025
3 tasks
49
MINOR: add missing link for KIP-1104 docs small Small PRs
#19271 opened Mar 24, 2025 by FrankYang0529 Loading… updated Mar 24, 2025
KAFKA-18616; Refactor Tools's ApiMessageFormatter do-not-merge PRs that are only open temporarily and should not be merged tools
#18695 opened Jan 24, 2025 by dajac Loading… updated Mar 24, 2025
8
KAFKA-18816: Add KIP-877 support to KafkaPrincipalBuilder clients
#18935 opened Feb 17, 2025 by mimaison Loading… updated Mar 24, 2025
1
KAFKA-18991: FetcherThread should match leader epochs between fetch request and fetch state ci-approved core Kafka Broker small Small PRs
#19223 opened Mar 18, 2025 by frankvicky Loading… updated Mar 24, 2025
7
KAFKA-16907: Fix RaftUtil's type complexity ci-approved kraft
#16831 opened Aug 8, 2024 by frankvicky Loading… updated Mar 24, 2025
3 tasks
12
KAFKA-18935: Ensure brokers do not return null records in FetchResponse ci-approved clients core Kafka Broker
#19167 opened Mar 9, 2025 by frankvicky Loading… updated Mar 24, 2025
7
KAFKA-17651: Implement describeUserScramCredentials ci-approved clients core Kafka Broker small Small PRs
#19066 opened Mar 1, 2025 by frankvicky Loading… updated Mar 24, 2025
KAFKA-18379: Enforce resigned cannot transition to any other state in same epoch ci-approved kraft small Small PRs triage PRs from the community
#19236 opened Mar 19, 2025 by frankvicky Loading… updated Mar 24, 2025
KAFKA-18561: Remove withKip853Rpc and replace it with withRaftProtocol ci-approved kraft tests Test fixes (including flaky tests)
#18600 opened Jan 17, 2025 by frankvicky Loading… updated Mar 24, 2025
3 tasks
@jsancio
36
KAFKA-16758: Extend Consumer#close with an option to leave the group or not ci-approved clients connect consumer ctr Consumer Threading Refactor (KIP-848) KIP-848 The Next Generation of the Consumer Rebalance Protocol storage Pull requests that target the storage module tiered-storage Related to the Tiered Storage feature
#17614 opened Oct 28, 2024 by frankvicky Loading… updated Mar 24, 2025
3 tasks
69
KAFKA-18877: Add an mechanism to find cases where we accessed variables from the wrong thread. kraft triage PRs from the community
#19231 opened Mar 18, 2025 by frankvicky • Draft updated Mar 24, 2025
KAFKA-18424: Consider splitting PlaintextAdminIntegrationTest#testConsumerGroups ci-approved core Kafka Broker needs-attention tests Test fixes (including flaky tests) triage PRs from the community
#19093 opened Mar 4, 2025 by frankvicky Loading… updated Mar 24, 2025
5
[MINOR] Cleanup Server Common Module ci-approved core Kafka Broker needs-attention triage PRs from the community
#19085 opened Mar 4, 2025 by sjhajharia Loading… updated Mar 24, 2025
7
ProTip! Exclude everything labeled bug with -label:bug.