使用kafkapublish处理器写入kafka主题时发送ssl close消息失败

fcg9iug3  于 2021-06-06  发布在  Kafka
关注(0)|答案(1)|浏览(430)

我使用kafkapublish处理器将消息发布到使用sasl\u ssl安全协议保护的kafka主题(我们不使用kerberos)。
我得到以下错误:

WARN Failed to send SSL Close message  
(org.apache.kafka.common.network.SslTransportLayer)
java.io.IOException: An existing connection was forcibly closed by the 
remote host
    at sun.nio.ch.SocketDispatcher.write0(Native Method)
    at sun.nio.ch.SocketDispatcher.write(SocketDispatcher.java:51)
    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:209)
    at org.apache.kafka.common.network.SslTransportLayer.close(SslTransportLayer.java:172)
    at org.apache.kafka.common.utils.Utils.closeAll(Utils.java:718)
    at org.apache.kafka.common.network.KafkaChannel.close(KafkaChannel.java:61)
    at org.apache.kafka.common.network.Selector.doClose(Selector.java:746)
    at org.apache.kafka.common.network.Selector.close(Selector.java:734)
    at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:532)
    at org.apache.kafka.common.network.Selector.poll(Selector.java:424)
    at kafka.network.Processor.poll(SocketServer.scala:628)
    at kafka.network.Processor.run(SocketServer.scala:545)
    at java.lang.Thread.run(Thread.java:748)

我可以从命令提示符发布到主题中。
当我使用 SASL_SSL 在kafkapublish中,kerberos服务名称是必填字段。但是既然我们不使用kerberos,我应该为这个字段设置什么值呢?

当我设置动态属性sasl.mechanism和sasl.jaas.configuration时,我得到了无效配置参数警告。
我是否缺少任何配置?任何帮助都将不胜感激。提前谢谢。

gpfsuwkq

gpfsuwkq1#

nifi的publishkafka只支持sasl和kerberos以外的机制,因为版本0\u11。
因此,如果需要使用sasl平原,您需要确保使用publishkafka\u0\u11或publishkafka\u1\u0。

相关问题