(kafka) branch trunk updated: MINOR: Remove unused SubscriptionState.hasPartitionsNeedingValidation (#23019)

[chia7712]

This is an automated email from the ASF dual-hosted git repository.

chia7712 pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 455cbdfea22 MINOR: Remove unused 
SubscriptionState.hasPartitionsNeedingValidation (#23019)
455cbdfea22 is described below

commit 455cbdfea22b088a101107e85e1ba87080b62d25
Author: Fatorin <sksly...@gmail.com>
AuthorDate: Sun Aug 2 11:40:10 2026 +0800

    MINOR: Remove unused SubscriptionState.hasPartitionsNeedingValidation 
(#23019)
    
    `SubscriptionState.hasPartitionsNeedingValidation` has no callers.
    
    It was added in #20324 alongside `PositionsValidator`, but that class
    ended up using the broader `SubscriptionState.hasAllFetchPositions()`
    for its skip check, so this method was never wired up.
    
    Reviewers: Chia-Ping Tsai <chia7...@gmail.com>
---
 .../kafka/clients/consumer/internals/SubscriptionState.java    | 10 ----------
 1 file changed, 10 deletions(-)

diff --git 
a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java
 
b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java
index 04135ca536f..56d38b0747a 100644
--- 
a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java
+++ 
b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java
@@ -902,16 +902,6 @@ public class SubscriptionState {
         return result;
     }
 
-    public synchronized boolean hasPartitionsNeedingValidation(long nowMs) {
-        for (TopicPartitionState tps  : assignment.partitionStateValues()) {
-            if (tps.awaitingValidation() && !tps.awaitingRetryBackoff(nowMs) 
&& tps.position != null) {
-                return true;
-            }
-        }
-
-        return false;
-    }
-
     public synchronized boolean isAssigned(TopicPartition tp) {
         return assignment.contains(tp);
     }