From 84d817f40ee43605985a0aef179f7a594701814a Mon Sep 17 00:00:00 2001 From: Chih-Yuan Chien Date: Wed, 20 Aug 2025 08:12:23 +0800 Subject: [PATCH] MINOR: Remove PartitionState (#20377) Remove unused PartitionState. It was unused after #7222. Reviewers: Chia-Ping Tsai , PoAn Yang --- .../common/internals/PartitionStates.java | 41 ------------------- 1 file changed, 41 deletions(-) diff --git a/clients/src/main/java/org/apache/kafka/common/internals/PartitionStates.java b/clients/src/main/java/org/apache/kafka/common/internals/PartitionStates.java index 96652df9410..1ce05571192 100644 --- a/clients/src/main/java/org/apache/kafka/common/internals/PartitionStates.java +++ b/clients/src/main/java/org/apache/kafka/common/internals/PartitionStates.java @@ -24,7 +24,6 @@ import java.util.Iterator; import java.util.LinkedHashMap; import java.util.List; import java.util.Map; -import java.util.Objects; import java.util.Set; import java.util.function.BiConsumer; @@ -151,46 +150,6 @@ public class PartitionStates { } } - public static class PartitionState { - private final TopicPartition topicPartition; - private final S value; - public PartitionState(TopicPartition topicPartition, S state) { - this.topicPartition = Objects.requireNonNull(topicPartition); - this.value = Objects.requireNonNull(state); - } - - public S value() { - return value; - } - - @Override - public boolean equals(Object o) { - if (this == o) - return true; - if (o == null || getClass() != o.getClass()) - return false; - - PartitionState that = (PartitionState) o; - - return topicPartition.equals(that.topicPartition) && value.equals(that.value); - } - - @Override - public int hashCode() { - int result = topicPartition.hashCode(); - result = 31 * result + value.hashCode(); - return result; - } - - public TopicPartition topicPartition() { - return topicPartition; - } - - @Override - public String toString() { - return "PartitionState(" + topicPartition + "=" + value + ')'; - } - } }