Skip to content

Conversation

@abhijeetk88
Copy link
Contributor

@abhijeetk88 abhijeetk88 commented Dec 15, 2025

Delete this text and replace it with a detailed description of your
change. The PR title and body will become the squashed commit message.

If you would like to tag individuals, add some commentary, upload
images, or include other supplemental information that should not be
part of the eventual commit message, please use a separate comment.

If applicable, please include a summary of the testing strategy
(including rationale) for the proposed change. Unit and/or integration
tests are expected for any behavior change and system tests should be
considered for larger changes.

@abhijeetk88 abhijeetk88 marked this pull request as draft December 15, 2025 13:23
@github-actions github-actions bot added triage PRs from the community core Kafka Broker storage Pull requests that target the storage module labels Dec 15, 2025
@abhijeetk88 abhijeetk88 changed the title FetchEarliestPendingUploadOffset API in LeaderEndPoint APIs for Follower Fetch from Last Tiered Offset Dec 15, 2025

if (localLogStartOffset.offset() == logStartOffset.offset()) {
// No segments have been uploaded yet
return logStartOffset;
Copy link
Contributor

Choose a reason for hiding this comment

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

can we refactor the code to avoid using multiple return statements?

https://tpolecat.github.io/2014/05/09/return.html

import scala.collection.Map
import scala.jdk.CollectionConverters._

class LocalLeaderEndPointRemoteTest extends LocalLeaderEndPointTestBase {
Copy link
Contributor

Choose a reason for hiding this comment

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

Why do we have to split the test? Can they be part of the existing LocalLeaderEndPointTest itself?

@github-actions github-actions bot removed the triage PRs from the community label Dec 17, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

core Kafka Broker storage Pull requests that target the storage module

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants