Skip to content

Commit 6760a4a

Browse files
authored
Merge pull request kroxylicious#1661 from SamBarker/sslTimeouts
revert Ssl timeouts
2 parents ae93811 + 66299e8 commit 6760a4a

File tree

2 files changed

+0
-3
lines changed

2 files changed

+0
-3
lines changed

kroxylicious-runtime/src/main/java/io/kroxylicious/proxy/internal/KafkaProxyFrontendHandler.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,6 @@
1212
import java.util.ArrayList;
1313
import java.util.List;
1414
import java.util.Objects;
15-
import java.util.concurrent.TimeUnit;
1615

1716
import org.apache.kafka.common.message.ApiVersionsRequestData;
1817
import org.apache.kafka.common.message.ApiVersionsResponseData;
@@ -481,7 +480,6 @@ void inConnecting(
481480
}
482481
virtualCluster.getUpstreamSslContext().ifPresent(sslContext -> {
483482
final SslHandler handler = sslContext.newHandler(outboundChannel.alloc(), remote.host(), remote.port());
484-
handler.setHandshakeTimeout(100, TimeUnit.MILLISECONDS);
485483
pipeline.addFirst("ssl", handler);
486484
});
487485

kroxylicious-runtime/src/test/java/io/kroxylicious/proxy/internal/KafkaProxyFrontendHandlerTest.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,6 @@ class KafkaProxyFrontendHandlerTest {
7575
public static final String SNI_HOSTNAME = "external.example.com";
7676
public static final String CLUSTER_HOST = "internal.example.org";
7777
public static final int CLUSTER_PORT = 9092;
78-
public static final String TLS_NEGOTIATION_ERROR = "TLS negotiation error";
7978
EmbeddedChannel inboundChannel;
8079
EmbeddedChannel outboundChannel;
8180

0 commit comments

Comments
 (0)