发送 SSL 关闭消息失败答案

【问题标题】：Failed to send SSL Close message发送 SSL 关闭消息失败
【发布时间】：2018-09-21 18:53:31
【问题描述】：

我有一个线程偶尔会列出消息中心上的主题。但偶尔，我会收到一条 :Failed to send SSL Close 消息。

有什么想法吗？

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 = 普通
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 需要 username="USERNAME" password="PASSWORD";

[警告] 2018-01-25 20:12:23.204 [ClusterChannelMonitorTaskThread] org.apache.kafka.common.network.SslTransportLayer {} - 发送失败 SSL 关闭消息 java.io.IOException：由返回的意外状态 SSLEngine.wrap，预期关闭，接收正常。不会发送关闭给对等方的消息。在 org.apache.kafka.common.network.SslTransportLayer.close(SslTransportLayer.java:158) [kafka-clients-0.11.0.0.jar:?] 在 org.apache.kafka.common.utils.Utils.closeAll(Utils.java:663) [kafka-clients-0.11.0.0.jar:?] 在 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:?] 在 org.apache.kafka.common.network.Selector.close(Selector.java:573) [kafka-clients-0.11.0.0.jar:?] 在 org.apache.kafka.common.network.Selector.close(Selector.java:539) [kafka-clients-0.11.0.0.jar:?] 在 org.apache.kafka.common.network.Selector.close(Selector.java:250) [kafka-clients-0.11.0.0.jar:?] 在 org.apache.kafka.clients.NetworkClient.close(NetworkClient.java:505) [kafka-clients-0.11.0.0.jar:?] 在 org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.close(ConsumerNetworkClient.java:439) [kafka-clients-0.11.0.0.jar:?] 在 org.apache.kafka.clients.ClientUtils.closeQuietly(ClientUtils.java:71) [kafka-clients-0.11.0.0.jar:?] 在 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:?] 在 org.apache.kafka.clients.consumer.KafkaConsumer.close(KafkaConsumer.java:1549) [kafka-clients-0.11.0.0.jar:?] 在 com.ibm.saas.msg.kafka.KafkaMessageService.listChannelNames(KafkaMessageService.java:305) [saas-msg-kafka-TRUNK-SNAPSHOT.jar:TRUNK-SNAPSHOT]

【问题讨论】：

看起来像 Kafka 中的一个错误。 SSLEngine 是一个很难正确驱动的东西。
在 Kafka 上提出问题：issues.apache.org/jira/browse/KAFKA-6510

标签： java apache-kafka kafka-consumer-api message-hub sslengine

【解决方案1】：

请确保您在 /etc/hosts 中设置了正确的值这非常重要。就我而言，我设置 listeners=SASL_SSL://10.10.10.3:9093 在 server.properties 文件中，所以我需要 10.10.10.3 SzymekKafka 在 /etc/hosts 中，其中 SzymekKafka 是我的主机名。

【讨论】：