gaurav-narula commented on code in PR #15655:
URL: https://github.com/apache/kafka/pull/15655#discussion_r1552109605
##########
clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java:
##########
@@ -1528,4 +1530,29 @@ public void
testHandshakeUnwrapContinuesUnwrappingOnNeedUnwrapAfterAllBytesRead(
assertEquals(SSLEngineResult.Status.OK, result.getStatus());
assertEquals(SSLEngineResult.HandshakeStatus.NEED_WRAP,
result.getHandshakeStatus());
}
+
+ @Test
+ public void testSSLEngineCloseInboundInvokedOnClose() throws IOException {
+ // Given
+ SSLEngine sslEngine = mock(SSLEngine.class);
Review Comment:
Thanks for the feedback! Addressed in
3eb2e99d91d51b313b5b224c9aa7dced1097fd30
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]