[ https://issues.apache.org/jira/browse/KAFKA-6510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
John Chu updated KAFKA-6510: ---------------------------- Summary: WARN: Failed to send SSL Close message java.io.IOException: Unexpected status returned by SSLEngine.wrap, expected CLOSED, received OK. (was: WARN: Fail to send SSL Close message) > WARN: Failed to send SSL Close message java.io.IOException: Unexpected status > returned by SSLEngine.wrap, expected CLOSED, received OK. > ---------------------------------------------------------------------------------------------------------------------------------------- > > Key: KAFKA-6510 > URL: https://issues.apache.org/jira/browse/KAFKA-6510 > Project: Kafka > Issue Type: Bug > Affects Versions: 0.11.0.0 > Reporter: John Chu > Priority: Major > > I have a thread which once in a while is going to list the topics on the > Message Hub. But once in a while, I am getting a :Failed to send SSL Close > message. > Any ideas? > Noticed there is another similar defect open: > https://issues.apache.org/jira/browse/KAFKA-3702 > Not sure if this is the same as that issue. . > Also another post from grokbase: > [http://grokbase.com/t/kafka/users/1653bm0a02/warn-failed-to-send-ssl-close-message] > > {code:java} > KafkaConsumer<String, String> consumer = new > KafkaConsumer<>(getConsumerConfiguration()); > try{ > Map<String, List<PartitionInfo>> topics = consumer.listTopics(); > return new ArrayList<String>(topics.keySet()); > } > finally{ > if (consumer != null){ > consumer.close(); > } > } > {code} > I am getting the warning from *consumer.close*. > The configuration of the consumer: > * sasl.mechanism = PLAIN > * security.protocol = SASL_SSL > * group.id = consumer1 > * ssl.enabled.protocol = TLSv1.2 > * ssl.endpoint.identification.algorithm = HTTPS > * ssl.protocol = TLSv1.2 > * sasl.jaas.config = org.apache.kafka.common.security.plain.PlainLoginModule > required username="USERNAME" password="PASSWORD"; > {quote}[WARN ] 2018-01-25 20:12:23.204 [ClusterChannelMonitorTaskThread] > org.apache.kafka.common.network.SslTransportLayer {} - Failed to send SSL > Close message java.io.IOException: Unexpected status returned by > SSLEngine.wrap, expected CLOSED, received OK. Will not send close message to > peer. at > org.apache.kafka.common.network.SslTransportLayer.close(SslTransportLayer.java:158) > [kafka-clients-0.11.0.0.jar:?] at > org.apache.kafka.common.utils.Utils.closeAll(Utils.java:663) > [kafka-clients-0.11.0.0.jar:?] at > org.apache.kafka.common.network.KafkaChannel.close(KafkaChannel.java:59) > [kafka-clients-0.11.0.0.jar:?] at > org.apache.kafka.common.network.Selector.doClose(Selector.java:582) > [kafka-clients-0.11.0.0.jar:?] at > org.apache.kafka.common.network.Selector.close(Selector.java:573) > [kafka-clients-0.11.0.0.jar:?] at > org.apache.kafka.common.network.Selector.close(Selector.java:539) > [kafka-clients-0.11.0.0.jar:?] at > org.apache.kafka.common.network.Selector.close(Selector.java:250) > [kafka-clients-0.11.0.0.jar:?] at > org.apache.kafka.clients.NetworkClient.close(NetworkClient.java:505) > [kafka-clients-0.11.0.0.jar:?] at > org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.close(ConsumerNetworkClient.java:439) > [kafka-clients-0.11.0.0.jar:?] at > org.apache.kafka.clients.ClientUtils.closeQuietly(ClientUtils.java:71) > [kafka-clients-0.11.0.0.jar:?] at > org.apache.kafka.clients.consumer.KafkaConsumer.close(KafkaConsumer.java:1613) > [kafka-clients-0.11.0.0.jar:?] at > org.apache.kafka.clients.consumer.KafkaConsumer.close(KafkaConsumer.java:1573) > [kafka-clients-0.11.0.0.jar:?] at > org.apache.kafka.clients.consumer.KafkaConsumer.close(KafkaConsumer.java:1549) > [kafka-clients-0.11.0.0.jar:?] at > {quote} -- This message was sent by Atlassian JIRA (v7.6.3#76005)