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

mjsax 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 6b5d172dcfa KAFKA-12828: Removed Deprecated methods under 
KeyQueryMetadata (#16747)
6b5d172dcfa is described below

commit 6b5d172dcfa305dcd9c140be13cd65d4c5656761
Author: abhi-ksolves <[email protected]>
AuthorDate: Wed Aug 7 06:51:23 2024 +0530

    KAFKA-12828: Removed Deprecated methods under KeyQueryMetadata (#16747)
    
    Reviewers: Matthias J. Sax <[email protected]>
---
 .../org/apache/kafka/streams/KeyQueryMetadata.java | 33 ----------------------
 1 file changed, 33 deletions(-)

diff --git 
a/streams/src/main/java/org/apache/kafka/streams/KeyQueryMetadata.java 
b/streams/src/main/java/org/apache/kafka/streams/KeyQueryMetadata.java
index 9f4311922be..7d10309b34f 100644
--- a/streams/src/main/java/org/apache/kafka/streams/KeyQueryMetadata.java
+++ b/streams/src/main/java/org/apache/kafka/streams/KeyQueryMetadata.java
@@ -49,39 +49,6 @@ public class KeyQueryMetadata {
         this.partition = partition;
     }
 
-    /**
-     * Get the active Kafka Streams instance for given key.
-     *
-     * @return active instance's {@link HostInfo}
-     * @deprecated since 2.7.0; use {@link #activeHost()} instead.
-     */
-    @Deprecated
-    public HostInfo getActiveHost() {
-        return activeHost;
-    }
-
-    /**
-     * Get the Kafka Streams instances that host the key as standbys.
-     *
-     * @return set of standby {@link HostInfo} or a empty set, if no standbys 
are configured
-     * @deprecated since 2.7.0; use {@link #standbyHosts()} instead.
-     */
-    @Deprecated
-    public Set<HostInfo> getStandbyHosts() {
-        return standbyHosts;
-    }
-
-    /**
-     * Get the store partition corresponding to the key.
-     *
-     * @return store partition number
-     * @deprecated since 2.7.0; use {@link #partition()} instead.
-     */
-    @Deprecated
-    public int getPartition() {
-        return partition;
-    }
-
     /**
      * Get the active Kafka Streams instance for given key.
      *

Reply via email to