无法发送SSL关闭消息

Question

我有一个线程,偶尔会在Message Hub上列出主题.但有一段时间,我得到了:无法发送SSL关闭消息.

有任何想法吗？

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();**
    }
}

我收到了来自consumer.close的警告.

消费者的配置:

• 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";

[WARN] 2018-01-25 20:12:23.204 [ClusterChannelMonitorTaskThread] org.apache.kafka.common.network.SslTransportLayer {} - 无法发送SSL关闭消息java.io.IOException:SSLEngine.wrap返回意外状态,预计CLOSED,收到OK.不会向同行发送密切消息.在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: ？] 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.ClientUti ls.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:？] 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 com.ibm.saas.msg.kafka.KafkaMessageService.listChannelNames(KafkaMessageService.java:305)[saas-msg -kafka-TRUNK-SNAPSHOT.jar:TRUNK-SNAPSHOT]