[KAFKA-2850] SslTransportLayerTest.testInvalidEndpointIdentification fails consistently

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.9.0.0
• Fix Version/s: 0.10.0.0
• Component/s: clients, security
• Assignee: Rajini Sivaram
• Reporter: Flavio Paiva Junqueira
• Created: 17/Nov/15 15:59
• Updated: 06/Jan/16 23:01
• Resolved: 06/Jan/16 23:01

Description

This test case is failing consistently for me. From the logs, I've noticed that waitForChannelClose is failing and the output is this:

[2015-11-17 15:51:50,374] WARN Failed to send SSL Close message  (org.apache.kafka.common.network.SslTransportLayer:164)
    java.nio.channels.ClosedChannelException
    	at sun.nio.ch.SocketChannelImpl.ensureWriteOpen(SocketChannelImpl.java:270)
    	at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:461)
    	at org.apache.kafka.common.network.SslTransportLayer.flush(SslTransportLayer.java:194)
    	at org.apache.kafka.common.network.SslTransportLayer.close(SslTransportLayer.java:161)
    	at org.apache.kafka.common.network.KafkaChannel.close(KafkaChannel.java:50)
    	at org.apache.kafka.common.network.Selector.close(Selector.java:442)
    	at org.apache.kafka.common.network.Selector.poll(Selector.java:310)
    	at org.apache.kafka.common.network.SslTransportLayerTest$SslEchoServer.run(SslTransportLayerTest.java:577)

org.apache.kafka.common.network.SslTransportLayerTest > testInvalidEndpointIdentification FAILED
    java.lang.AssertionError
        at org.junit.Assert.fail(Assert.java:86)
        at org.junit.Assert.assertTrue(Assert.java:41)
        at org.junit.Assert.assertTrue(Assert.java:52)
        at org.apache.kafka.common.network.SslTransportLayerTest.waitForChannelClose(SslTransportLayerTest.java:430)
        at org.apache.kafka.common.network.SslTransportLayerTest.testInvalidEndpointIdentification(SslTransportLayerTest.java:124)