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 d4caa1c10ec MINOR: Remove redundant ApiVersionsResponse#filterApis 
(#15611)
d4caa1c10ec is described below

commit d4caa1c10ec81b9c87eaaf52b73c83d5579b68d3
Author: Kuan-Po (Cooper) Tseng <brandb...@gmail.com>
AuthorDate: Sun Mar 31 11:22:16 2024 +0800

    MINOR: Remove redundant ApiVersionsResponse#filterApis (#15611)
    
    Reviewers: Chia-Ping Tsai <chia7...@gmail.com>
---
 .../java/org/apache/kafka/common/requests/ApiVersionsResponse.java | 7 -------
 .../java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java  | 2 +-
 2 files changed, 1 insertion(+), 8 deletions(-)

diff --git 
a/clients/src/main/java/org/apache/kafka/common/requests/ApiVersionsResponse.java
 
b/clients/src/main/java/org/apache/kafka/common/requests/ApiVersionsResponse.java
index f8f364f06f7..04ee2014d1d 100644
--- 
a/clients/src/main/java/org/apache/kafka/common/requests/ApiVersionsResponse.java
+++ 
b/clients/src/main/java/org/apache/kafka/common/requests/ApiVersionsResponse.java
@@ -166,13 +166,6 @@ public class ApiVersionsResponse extends AbstractResponse {
         );
     }
 
-    public static ApiVersionCollection filterApis(
-        RecordVersion minRecordVersion,
-        ApiMessageType.ListenerType listenerType
-    ) {
-        return filterApis(minRecordVersion, listenerType, false, false);
-    }
-
     public static ApiVersionCollection filterApis(
         RecordVersion minRecordVersion,
         ApiMessageType.ListenerType listenerType,
diff --git 
a/clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java
 
b/clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java
index 71e802365fd..3f9f3707479 100644
--- 
a/clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java
+++ 
b/clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java
@@ -712,7 +712,7 @@ public class KafkaAdminClientTest {
         if (error == Errors.NONE) {
             return ApiVersionsResponse.createApiVersionsResponse(
                 0,
-                ApiVersionsResponse.filterApis(RecordVersion.current(), 
ApiMessageType.ListenerType.ZK_BROKER),
+                ApiVersionsResponse.filterApis(RecordVersion.current(), 
ApiMessageType.ListenerType.ZK_BROKER, false, false),
                 
convertSupportedFeaturesMap(defaultFeatureMetadata().supportedFeatures()),
                 Collections.singletonMap("test_feature_1", (short) 2),
                 defaultFeatureMetadata().finalizedFeaturesEpoch().get(),

Reply via email to