英文:
Not able to produce to 3.2.1 secure kafka(SASL_PLAINTEXT and SCRAM-SHA-512) using the nifi 1.9.2
问题
我需要使用版本为0.8.2.1的Kafka，并在使用版本为1.9.2的Nifi中使用GetKafka进行消费。然后，在同一个1.9.2版本的Nifi中，我需要使用PublishKafka_2_0将数据发送到具有SASL_PLAINTEXT安全性和SCRAM-SHA-512的Kafka 3.2.1集群。当我配置了所有必要的内容，如用户名、密码和sasl.jaas.config动态配置时，它要求提供Kerberos服务名称。经过一些调试和研究，我发现SASL_PLAINTEXT只支持具有Kerberos的GSAPI。
但后来我尝试了升级的Nifi版本1.18.0，我可以使用PublishKafka_2_6，可以轻松地将数据生产到安全主题上，该主题在3.2.1版本的Kafka中使用SASL_PLAINTEXT和SCRAM-SHA-512。但在这个Nifi版本(1.18.0)中，没有GetKafka，因此无法从0.8.2.1版本的Kafka主题中进行消费。
如何解决这个问题，因为我找不到任何解决方案？
英文:
I need to consume from 0.8.2.1 version kafka using the GetKafka in nifi which we are using the version 1.9.2. From there using the PublishKafka_2_0 in same 1.9.2 nifi I need to send to the same topic for the kafka 3.2.1 cluster which is having the SASL_PLAINTEXT security and SCRAM-SHA-512. when i configured all the required things like username and password and sasl.jaas.config dynamically it is asking for the kerberos service name . After few debugging and study I found that SASL_PLAINTEXT is only supported with GSAPI which is Kerberos.
But then i tried with upgraded nifi version 1.18.0 which i can use the PublishKafka_2_6 where i can quite comfortably produce to the secured topic on 3.2.1 version kafka which is of SASL_PLAINTEXT and SCRAM-SHA-512 . But here issue is in this version of nifi(1.18.0) there is no GetKafka inorder to consumer from the 0.8.2.1 kafka topic.
how to resolve this issue as i cannot find any solution to this?
答案1
得分: 0
你应该能够通过访问Maven中央仓库获取不再默认包含的任何旧版NAR文件：
https://repo1.maven.org/maven2/org/apache/nifi/nifi-kafka-0-8-nar/
英文:
You should be able to obtain any of the older NARs that are no longer included by default by going to Maven central:
https://repo1.maven.org/maven2/org/apache/nifi/nifi-kafka-0-8-nar/
通过集体智慧和协作来改善编程学习和解决问题的方式。致力于成为全球开发者共同参与的知识库，让每个人都能够通过互相帮助和分享经验来进步。
评论