8

我有一个线程偶尔会列出消息中心上的主题。但有时，我会收到一条 :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 = PLAIN
  • security.protocol = SASL_SSL
  • group.id = 消费者1
  • ssl.enabled.protocol = TLSv1.2
  • ssl.endpoint.identification.algorithm = HTTPS
  • ssl.protocol = TLSv1.2
  • sasl.jaas.config = org.apache.kafka.common.security.plain.PlainLoginModule 需要用户名=“用户名”密码=“密码”；

[警告] 2018-01-25 20:12:23.204 [ClusterChannelMonitorTaskThread] org.apache.kafka.common.network.SslTransportLayer {} - 无法发送 SSL 关闭消息 java.io.IOException：SSLEngine.wrap 返回的意外状态，预计关闭，收到OK。不会向对等方发送关闭消息。在 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: ?] 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:

4

2 回答 2

0

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

于 2018-09-21T10:53:31.453 回答
-1

今天使用 kafka 客户端 1.0.2 也遇到了这个异常：/

于 2018-09-20T16:04:48.423 回答