kafka中的SSL安全认证配置问题

太随意 发表于: 2017-08-08   最后更新时间: 2017-08-08 15:51:55   4,647 游览

配置文件中/var/private/ssl/kafka.server.keystore.jks这个路径是怎么来的？我照着大神的文档搭建的时候没看到生成这个文件啊？？？？？

kafka
发表于 2017-08-08
太随意
添加评论

keytool -keystore server.keystore.jks -alias localhost -validity 365 -genkey

回复
回答于 7年前
半兽人
太随意 -> 半兽人 7年前

好的，谢谢大神

0 0 回复

你好，我安装您的文档配置了单台kafka测试生产者，没有通过，

WARN Error while fetching metadata with correlation id 0 : {test=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)

[2018-12-12 06:48:31,461] WARN Error while fetching metadata with correlation id 1 : {test=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)

[2018-12-12 06:48:31,568] WARN Error while fetching metadata with correlation id 2 : {test=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)

[2018-12-12 06:48:31,678] WARN Error while fetching metadata with correlation id 3 : {test=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)

[2018-12-12 06:48:31,787] WARN Error while fetching metadata with correlation id 4 : {test=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)

[2018-12-12 06:48:31,894] WARN Error while fetching metadata with correlation id 5 : {test=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)

[2018-12-12 06:48:32,002] WARN Error while fetching metadata with correlation id 6 : {test=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)

[2018-12-12 06:48:32,111] WARN Error while fetching metadata with correlation id 7 : {test=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)

[2018-12-12 06:48:33,713] WARN Bootstrap broker 127.0.0.1:5044 disconnected (org.apache.kafka.clients.NetworkClient)

[2018-12-12 06:48:38,977] WARN Error while fetching metadata with correlation id 9 : {test=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)

[2018-12-12 06:48:39,087] WARN Error while fetching metadata with correlation id 10 : {test=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)

0 0 回复

你好，你是怎么配置的呢？我现在遇到和你差不多的问题，
ARN Failed to send SSL Close message  (org.apache.kafka.common.network.SslTransportLayer)
java.io.IOException: Broken pipe
 at sun.nio.ch.FileDispatcherImpl.write0(Native Method)
 at sun.nio.ch.SocketDispatcher.write(SocketDispatcher.java:47)
 at sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:93)
 at sun.nio.ch.IOUtil.write(IOUtil.java:65)
 at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:471)
 at org.apache.kafka.common.network.SslTransportLayer.flush(SslTransportLayer.java:195)
 at org.apache.kafka.common.network.SslTransportLayer.close(SslTransportLayer.java:163)
 at org.apache.kafka.common.utils.Utils.closeAll(Utils.java:690)
 at org.apache.kafka.common.network.KafkaChannel.close(KafkaChannel.java:47)
 at org.apache.kafka.common.network.Selector.close(Selector.java:487)
 at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:368)
 at org.apache.kafka.common.network.Selector.poll(Selector.java:291)
 at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:260)
 at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:236)
 at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:135)
 at java.lang.Thread.run(Thread.java:745)

回复
回答于 6年前
°深海少年与鲸
你的答案

查看kafka相关的其他问题或提一个您自己的问题。
提问

找不到想要的答案？提一个您自己的问题。