Skip to content

Pull requests: apache/kafka

New pull request New
233 Open 20,741 Closed
233 Open 20,741 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: Correcting the throttling condition for batch in Share Partition (#20978) ci-approved
#20988 opened Nov 25, 2025 by apoorvmittal10 Loading…
MINOR: Adding check for invalid batch from persister in Share Partition (#20979) ci-approved
#20987 opened Nov 25, 2025 by apoorvmittal10 Loading…
KAFKA-19888: Clamp negative values in coordinator histograms ci-approved group-coordinator small Small PRs triage PRs from the community
#20986 opened Nov 25, 2025 by squah-confluent Loading…
1
MINOR: Skip testDsaKeyPair when DSA algorithm is not supported ci-approved
#20985 opened Nov 25, 2025 by jiafu1115 Loading…
KAFKA-19913 Add comprehensive unit tests for VerifiableProperties class core Kafka Broker tests Test fixes (including flaky tests) triage PRs from the community
#20984 opened Nov 25, 2025 by devtrace404 Loading…
1
KAFKA-19249: Replace Consumer#close(Duration) with Consumer#close(CloseOptions) ci-approved clients consumer core Kafka Broker small Small PRs storage Pull requests that target the storage module tiered-storage Related to the Tiered Storage feature
#20983 opened Nov 25, 2025 by jack2012aa Loading…
3
KAFKA-15700: FetchFromFollowerIntegrationTest is flaky ci-approved core Kafka Broker small Small PRs tests Test fixes (including flaky tests)
#20982 opened Nov 25, 2025 by jack2012aa Loading…
3
MINOR: Bump LATEST_PRODUCTION for 4.2-IV1 core Kafka Broker kraft small Small PRs tools
#20977 opened Nov 24, 2025 by AndrewJSchofield Loading…
3
MINOR: Fix rare flaky behaviour in testPreferredReplicaElection small Small PRs tests Test fixes (including flaky tests) tools
#20976 opened Nov 24, 2025 by MahsaSeifikar Loading…
3
MINOR: Backport fix for test_fencing_static_consumer system test to 3.9
#20974 opened Nov 24, 2025 by apalan60 Loading…
MINOR: Move ShareAcquireMode to consumer.internal package ci-approved clients consumer core Kafka Broker KIP-932 Queues for Kafka small Small PRs
#20973 opened Nov 24, 2025 by JimmyWang6 Loading…
1
MINOR: Bump LATEST_PRODUCTION to 4.2-IV1 in 4.2 branch
#20972 opened Nov 24, 2025 by AndrewJSchofield Loading…
11
KAFKA-17521: Avoid WARN on cleanup when state directory only contains process metadata. ci-approved small Small PRs streams triage PRs from the community
#20969 opened Nov 23, 2025 by chickenchickenlove Loading…
KAFKA-16366: Refactor KTable source optimization streams triage PRs from the community
#20968 opened Nov 23, 2025 by chickenchickenlove Loading…
KAFKA-19891: Suppress error-level heartbeat logs during consumer close ci-approved clients consumer small Small PRs
#20965 opened Nov 22, 2025 by AntonVasant Loading…
2
MINOR: Improve JavaDoc for LEAVING state transition in AbstractHeartbeatRequestManager ci-approved clients consumer small Small PRs triage PRs from the community
#20964 opened Nov 22, 2025 by AntonVasant Loading…
KAFKA-19875 Duplicated topic config prevents broker start
#20960 opened Nov 22, 2025 by m1a2st Loading…
4
MINOR: Add startup-duration logging to help with Kafka startup performance tuning ci-approved core Kafka Broker small Small PRs triage PRs from the community
#20959 opened Nov 22, 2025 by jiafu1115 Loading…
KAFKA-19831: Improved error handling in DefaultStateUpdater. (#20767) streams
#20958 opened Nov 22, 2025 by Nikita-Shupletsov Loading…
2
MINOR: Address flaky wait for producer acks logging for checking when not al… small Small PRs tests Test fixes (including flaky tests)
#20957 opened Nov 21, 2025 by bbejeck Loading…
13
KAFKA-14711: Add new StateStore interfaces streams triage PRs from the community
#20955 opened Nov 21, 2025 by nicktelford Loading…
KAFKA-14412: Use shared cache for Task offset sums streams triage PRs from the community
#20954 opened Nov 21, 2025 by nicktelford Loading…
1
MINOR: Update jackson to 2.20.1 and jackson-annotations to 2.20 build Gradle build or GitHub Actions ci-approved core Kafka Broker dependencies Pull requests that update a dependency file generator RPC and Record code generator small Small PRs tools triage PRs from the community
#20951 opened Nov 21, 2025 by Philippus Loading…
2
KAFKA-19905: Fix tight reconnection loop during shutdown core Kafka Broker small Small PRs triage PRs from the community
#20950 opened Nov 21, 2025 by fvaleri • Draft
MINOR: update method name from createGroupTombstoneRecords to createGroupTombStoneRecordsAndCancelTimers ci-approved group-coordinator small Small PRs
#20949 opened Nov 21, 2025 by RaidenE1 Loading…
@lucasbru
10
ProTip! Find all pull requests that aren't related to any open issues with -linked:issue.