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(),