KAFKA-16330: Remove deprecated methods of TaskId and make deprecated …

…members private (#16985) Reviewers: Chia-Ping Tsai <[email protected]>, Matthias J. Sax <[email protected]>
apache · Aug 26, 2024 · bf914b6 · bf914b6
1 parent e8b27b6
commit bf914b6
Showing 1 changed file with 2 additions and 45 deletions.
diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/TaskId.java b/streams/src/main/java/org/apache/kafka/streams/processor/TaskId.java
@@ -21,15 +21,8 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import java.io.DataInputStream;
-import java.io.DataOutputStream;
-import java.io.IOException;
-import java.nio.ByteBuffer;
 import java.util.Objects;
 
-import static org.apache.kafka.streams.processor.internals.assignment.ConsumerProtocolUtils.readTaskIdFrom;
-import static org.apache.kafka.streams.processor.internals.assignment.ConsumerProtocolUtils.writeTaskIdTo;
-
 /**
  * The task ID representation composed as subtopology (aka topicGroupId) plus the assigned partition ID.
  */
@@ -40,11 +33,9 @@ public class TaskId implements Comparable<TaskId> {
     public static final String NAMED_TOPOLOGY_DELIMITER = "__";
 
     /** The ID of the subtopology, aka topicGroupId. */
-    @Deprecated
-    public final int topicGroupId;
+    private final int topicGroupId;
     /** The ID of the partition. */
-    @Deprecated
-    public final int partition;
+    private final int partition;
 
     /** The namedTopology that this task belongs to, or null if it does not belong to one */
     private final String topologyName;
@@ -114,40 +105,6 @@ public static TaskId parse(final String taskIdStr) {
         }
     }
 
-    /**
-     * @throws IOException if cannot write to output stream
-     * @deprecated since 3.0, for internal use, will be removed
-     */
-    @Deprecated
-    public void writeTo(final DataOutputStream out, final int version) throws IOException {
-        writeTaskIdTo(this, out, version);
-    }
-
-    /**
-     * @throws IOException if cannot read from input stream
-     * @deprecated since 3.0, for internal use, will be removed
-     */
-    @Deprecated
-    public static TaskId readFrom(final DataInputStream in, final int version) throws IOException {
-        return readTaskIdFrom(in, version);
-    }
-
-    /**
-     * @deprecated since 3.0, for internal use, will be removed
-     */
-    @Deprecated
-    public void writeTo(final ByteBuffer buf, final int version) {
-        writeTaskIdTo(this, buf, version);
-    }
-
-    /**
-     * @deprecated since 3.0, for internal use, will be removed
-     */
-    @Deprecated
-    public static TaskId readFrom(final ByteBuffer buf, final int version) {
-        return readTaskIdFrom(buf, version);
-    }
-
     @Override
     public boolean equals(final Object o) {
         if (this == o) {