(kafka) branch trunk updated: MINOR: Remove unused DescribeTopicPartitionResponse.prepareResponse function (#20032)

[frankvicky]

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

frankvicky 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 2d943419a35 MINOR: Remove unused 
DescribeTopicPartitionResponse.prepareResponse function (#20032)
2d943419a35 is described below

commit 2d943419a35487a23a28fbd7c21087c39a75caf1
Author: Yu-Syuan Jheng <andyretaj...@gmail.com>
AuthorDate: Wed Jun 25 05:26:22 2025 -0400

    MINOR: Remove unused DescribeTopicPartitionResponse.prepareResponse 
function (#20032)
    
    The prepareResponse function is no longer used anywhere in the codebase.
    Removing unused code improves maintainability and readability.
    
    Reviewers: PoAn Yang <pay...@apache.org>, Yung
    <yungyung7654...@gmail.com>, TengYao Chi <frankvi...@apache.org>, Ken
    Huang <s7133...@gmail.com>
---
 .../common/requests/DescribeTopicPartitionsResponse.java     | 12 ------------
 1 file changed, 12 deletions(-)

diff --git 
a/clients/src/main/java/org/apache/kafka/common/requests/DescribeTopicPartitionsResponse.java
 
b/clients/src/main/java/org/apache/kafka/common/requests/DescribeTopicPartitionsResponse.java
index 02a3cecc0be..04350480ac8 100644
--- 
a/clients/src/main/java/org/apache/kafka/common/requests/DescribeTopicPartitionsResponse.java
+++ 
b/clients/src/main/java/org/apache/kafka/common/requests/DescribeTopicPartitionsResponse.java
@@ -20,13 +20,11 @@ package org.apache.kafka.common.requests;
 import org.apache.kafka.common.Node;
 import org.apache.kafka.common.TopicPartitionInfo;
 import org.apache.kafka.common.message.DescribeTopicPartitionsResponseData;
-import 
org.apache.kafka.common.message.DescribeTopicPartitionsResponseData.DescribeTopicPartitionsResponseTopic;
 import org.apache.kafka.common.protocol.ApiKeys;
 import org.apache.kafka.common.protocol.Errors;
 import org.apache.kafka.common.protocol.Readable;
 
 import java.util.EnumMap;
-import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;
 
@@ -68,16 +66,6 @@ public class DescribeTopicPartitionsResponse extends 
AbstractResponse {
         return errorCounts;
     }
 
-    public static DescribeTopicPartitionsResponse prepareResponse(
-        int throttleTimeMs,
-        List<DescribeTopicPartitionsResponseTopic> topics
-    ) {
-        DescribeTopicPartitionsResponseData responseData = new 
DescribeTopicPartitionsResponseData();
-        responseData.setThrottleTimeMs(throttleTimeMs);
-        topics.forEach(topicResponse -> 
responseData.topics().add(topicResponse));
-        return new DescribeTopicPartitionsResponse(responseData);
-    }
-
     public static DescribeTopicPartitionsResponse parse(Readable readable, 
short version) {
         return new DescribeTopicPartitionsResponse(
             new DescribeTopicPartitionsResponseData(readable, version));