From f4157be6ca6df2cab91a85c20f9156e4d6009eda Mon Sep 17 00:00:00 2001 From: Jhen-Yung Hsu Date: Tue, 7 Oct 2025 20:34:48 +0800 Subject: [PATCH 1/2] MINOR: try new ci-complete logic --- .../java/org/apache/kafka/common/network/SslTransportLayer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/clients/src/main/java/org/apache/kafka/common/network/SslTransportLayer.java b/clients/src/main/java/org/apache/kafka/common/network/SslTransportLayer.java index d047c79ce8a1c..6eca0d2858165 100644 --- a/clients/src/main/java/org/apache/kafka/common/network/SslTransportLayer.java +++ b/clients/src/main/java/org/apache/kafka/common/network/SslTransportLayer.java @@ -917,7 +917,7 @@ private void handshakeFailure(SSLException sslException, boolean flush) { // unable to process the server message and an SSLException is thrown: // javax.net.ssl.SSLException: Unrecognized SSL message, plaintext connection? // b) If server closes the connection gracefully during handshake, client may receive close_notify - // and and an SSLException is thrown: + // and an SSLException is thrown: // javax.net.ssl.SSLException: Received close_notify during handshake // We want to handle a) as a non-retriable SslAuthenticationException and b) as a retriable IOException. // To do this we need to rely on the exception string. Since it is safer to throw a retriable exception From e85c78a6be496ca1243d6dea288dd3fdc00bf784 Mon Sep 17 00:00:00 2001 From: Jhen-Yung Hsu Date: Fri, 17 Oct 2025 01:11:43 +0800 Subject: [PATCH 2/2] Retrigger CI --- .../kafka/clients/producer/internals/ProduceRequestResult.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/clients/src/main/java/org/apache/kafka/clients/producer/internals/ProduceRequestResult.java b/clients/src/main/java/org/apache/kafka/clients/producer/internals/ProduceRequestResult.java index 9077b107ab03e..89ea0789f389a 100644 --- a/clients/src/main/java/org/apache/kafka/clients/producer/internals/ProduceRequestResult.java +++ b/clients/src/main/java/org/apache/kafka/clients/producer/internals/ProduceRequestResult.java @@ -41,7 +41,7 @@ public class ProduceRequestResult { /** * Create an instance of this class. * - * @param topicPartition The topic and partition to which this record set was sent was sent + * @param topicPartition The topic and partition to which this record set was sent */ public ProduceRequestResult(TopicPartition topicPartition) { this.topicPartition = topicPartition;