无法发送ssl关闭消息

mftmpeh8  于 2021-06-07  发布在  Kafka
关注(0)|答案(2)|浏览(253)

我有一个线程,偶尔会列出消息中心的主题。但偶尔,我会收到一个:发送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();**
    }
}

我收到消费者的警告。关闭。
耗电元件的配置:
sasl.mechanism=普通
security.protocol=sasl\u 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:?]在org.apache.kafka.common.network.selector.doclose(选择器。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(选择器。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.closequiety(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中继快照。jar:trunk-snapshot]

qlckcl4x

qlckcl4x1#

请确保在/etc/hosts中设置了正确的值,这非常重要。在我的情况下,我设置 listeners=SASL_SSL://10.10.10.3:9093 在server.properties文件中,所以我需要 10.10.10.3 SzymekKafka 在/etc/hosts中,szymekkafka是我的主机名。

yfwxisqw

yfwxisqw2#

今天kafka客户端1.0.2也出现了这个异常:/

相关问题