Skip to content

Conversation

@kamalcph
Copy link
Contributor

@kamalcph kamalcph commented Oct 17, 2025

  • Updated the delayed remote fetch purgatory cleanup comment

Reviewers: Luke Chen showuon@gmail.com

@github-actions github-actions bot added core Kafka Broker triage PRs from the community small Small PRs labels Oct 17, 2025
@kamalcph kamalcph changed the title MINOR: Update the delayed remote fetch purgatory cleanup comment KAFKA-19806: Hook to enable / disable multi-partition remote fetch feature Oct 17, 2025
@kamalcph kamalcph requested review from satishd and showuon October 17, 2025 08:59
@kamalcph
Copy link
Contributor Author

@showuon @satishd

Added a hook to enable / disable the multi-partition remote fetch feature. The broker config 'remote.multi.partition.fetch.enable' can be introduced later. Could you please review the PR? Thanks!

Comment on lines -1743 to -1744
// We only guarantee eventual cleanup via the next FETCH request for the same set of partitions or
// using reaper-thread.
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Ah, wrong place. Nice find!

@kamalcph kamalcph changed the title KAFKA-19806: Hook to enable / disable multi-partition remote fetch feature MINOR: Update the delayed remote fetch purgatory cleanup comment Oct 21, 2025
val fetchPartitionData = localReadResults.map { case (tp, result) =>
val remoteFetchResult = remoteFetchResults.get(tp)
if (remoteFetchInfos.containsKey(tp)
if (remoteFetchResults.containsKey(tp)
Copy link
Contributor Author

@kamalcph kamalcph Oct 21, 2025

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This change is minor one and required when enabling single-partition fetch. Let me know if you want to take this up in the next PR.

Copy link
Member

@showuon showuon left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM!

@kamalcph kamalcph merged commit 32dedbd into apache:trunk Oct 22, 2025
27 checks passed
@kamalcph kamalcph deleted the minor branch October 22, 2025 03:16
@github-actions github-actions bot removed the triage PRs from the community label Oct 22, 2025
joshua2519 pushed a commit to joshua2519/kafka that referenced this pull request Oct 27, 2025
…che#20721)

- Updated the delayed remote fetch purgatory cleanup comment

Reviewers: Luke Chen <showuon@gmail.com>
eduwercamacaro pushed a commit to littlehorse-enterprises/kafka that referenced this pull request Nov 12, 2025
…che#20721)

- Updated the delayed remote fetch purgatory cleanup comment

Reviewers: Luke Chen <showuon@gmail.com>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

core Kafka Broker small Small PRs

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants