Skip to content

Commit

Permalink
revert unecessary change
Browse files Browse the repository at this point in the history
  • Loading branch information
TaiJuWu committed Sep 29, 2024
1 parent b8b9e27 commit 1820990
Showing 1 changed file with 1 addition and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -240,7 +240,6 @@ private void process(final ConsumerRebalanceListenerCallbackNeededEvent event) {
private Optional<ClientTelemetryReporter> clientTelemetryReporter = Optional.empty();

// to keep from repeatedly scanning subscriptions in poll(), cache the result during metadata updates
// and record there is a resetOffsetEvent in background thread.
private boolean cachedSubscriptionHasAllFetchPositions;
private final WakeupTrigger wakeupTrigger = new WakeupTrigger();
private final OffsetCommitCallbackInvoker offsetCommitCallbackInvoker;
Expand Down Expand Up @@ -863,9 +862,8 @@ public long position(TopicPartition partition, Duration timeout) {
Timer timer = time.timer(timeout);
do {
SubscriptionState.FetchPosition position = subscriptions.validPosition(partition);
if (position != null) {
if (position != null)
return position.offset;
}

updateFetchPositions(timer);
timer.update();
Expand Down

0 comments on commit 1820990

Please sign in to comment.