°深海少年与鲸

0 声望

这家伙太懒，什么都没留下

个人动态
  • 关注了用户 曦云 · 6年前
  • °深海少年与鲸 回复 半兽人 在 kafka中的SSL安全认证配置问题 中 ：

    你好，我安装您的文档配置了单台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)

    6年前
  • 关注了用户 半兽人 · 6年前
  • °深海少年与鲸 在 kafka中的SSL安全认证配置问题 发表评论：

    你好，你是怎么配置的呢？我现在遇到和你差不多的问题，
    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收到的消息写入到HDFS中进行统计分析？ 中 ：

    具体地址给一下可以么，配置的例子

    6年前