(kafka) branch trunk updated: KAFKA-18037 Remove deprecated methods from EmbeddedConnect and EmbeddedConnectCluster (#17857)

[chia7712]

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 337e2e15065 KAFKA-18037 Remove deprecated methods from EmbeddedConnect 
and EmbeddedConnectCluster (#17857)
337e2e15065 is described below

commit 337e2e150657b504cd77a91afe8cc4d160c2124c
Author: Logan Zhu <loganzh...@outlook.com>
AuthorDate: Sat Nov 23 23:16:41 2024 +0800

    KAFKA-18037 Remove deprecated methods from EmbeddedConnect and 
EmbeddedConnectCluster (#17857)
    
    Reviewers: Chia-Ping Tsai <chia7...@gmail.com>
---
 .../connect/util/clusters/EmbeddedConnect.java     | 55 ----------------------
 .../util/clusters/EmbeddedConnectCluster.java      |  8 ----
 2 files changed, 63 deletions(-)

diff --git 
a/connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnect.java
 
b/connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnect.java
index efd306bd397..e76ccf9ed2c 100644
--- 
a/connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnect.java
+++ 
b/connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnect.java
@@ -914,19 +914,6 @@ abstract class EmbeddedConnect {
         return kafkaCluster;
     }
 
-    /**
-     * Execute a GET request on the given URL.
-     *
-     * @param url the HTTP endpoint
-     * @return the response to the GET request
-     * @throws ConnectException if execution of the GET request fails
-     * @deprecated Use {@link #requestGet(String)} instead.
-     */
-    @Deprecated
-    public String executeGet(String url) {
-        return responseToString(requestGet(url));
-    }
-
     /**
      * Execute a GET request on the given URL.
      *
@@ -938,20 +925,6 @@ abstract class EmbeddedConnect {
         return requestHttpMethod(url, null, Collections.emptyMap(), "GET");
     }
 
-    /**
-     * Execute a PUT request on the given URL.
-     *
-     * @param url the HTTP endpoint
-     * @param body the payload of the PUT request
-     * @return the response to the PUT request
-     * @throws ConnectException if execution of the PUT request fails
-     * @deprecated Use {@link #requestPut(String, String)} instead.
-     */
-    @Deprecated
-    public int executePut(String url, String body) {
-        return requestPut(url, body).getStatus();
-    }
-
     /**
      * Execute a PUT request on the given URL.
      *
@@ -964,21 +937,6 @@ abstract class EmbeddedConnect {
         return requestHttpMethod(url, body, Collections.emptyMap(), "PUT");
     }
 
-    /**
-     * Execute a POST request on the given URL.
-     *
-     * @param url the HTTP endpoint
-     * @param body the payload of the POST request
-     * @param headers a map that stores the POST request headers
-     * @return the response to the POST request
-     * @throws ConnectException if execution of the POST request fails
-     * @deprecated Use {@link #requestPost(String, String, java.util.Map)} 
instead.
-     */
-    @Deprecated
-    public int executePost(String url, String body, Map<String, String> 
headers) {
-        return requestPost(url, body, headers).getStatus();
-    }
-
     /**
      * Execute a POST request on the given URL.
      *
@@ -1004,19 +962,6 @@ abstract class EmbeddedConnect {
         return requestHttpMethod(url, body, Collections.emptyMap(), "PATCH");
     }
 
-    /**
-     * Execute a DELETE request on the given URL.
-     *
-     * @param url the HTTP endpoint
-     * @return the response to the DELETE request
-     * @throws ConnectException if execution of the DELETE request fails
-     * @deprecated Use {@link #requestDelete(String)} instead.
-     */
-    @Deprecated
-    public int executeDelete(String url) {
-        return requestDelete(url).getStatus();
-    }
-
     /**
      * Execute a DELETE request on the given URL.
      *
diff --git 
a/connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnectCluster.java
 
b/connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnectCluster.java
index ceb3a6c6af6..0a5554c3937 100644
--- 
a/connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnectCluster.java
+++ 
b/connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnectCluster.java
@@ -202,14 +202,6 @@ public class EmbeddedConnectCluster extends 
EmbeddedConnect {
             return this;
         }
 
-        /**
-         * @deprecated Use {@link #clientProps(Map)} instead.
-         */
-        @Deprecated
-        public Builder clientConfigs(Map<String, String> clientProps) {
-            return clientProps(clientProps);
-        }
-
         @Override
         protected EmbeddedConnectCluster build(
                 int numBrokers,