如何通过publishkafka处理器将nifi连接到IBMMessageHub?

3htmauhk  于 2021-06-24  发布在  Kafka
关注(0)|答案(1)|浏览(392)

我正在尝试将nifi连接到ibmmessagehub,但没有任何连接工作。
有没有人有一个关于如何配置它的工作示例?
我在公告栏里发现了一个超时异常。
我已经配置了一个publishkafka\u 0\u 11 1.4.0处理器。将其配置为sasl\u ssl,添加了标准ssl上下文服务,添加了jaas.conf

KafkaClient {
  org.apache.kafka.common.security.plain.PlainLoginModule required
  serviceName="Message Hub-bq"
  username="xxxxxx"
  password="xxxxxx";
};

在日志中我得到:
2017-11-24 13:47:01407 info[kafka producer network thread | producer-1]o.a.k.common.network.saslchannelbuilder未能创建频道,原因是org.apache.kafka.common.kafkaexception:未能配置saslclientauthenticator

2lpgd968

2lpgd9681#

从您提供的配置来看,似乎缺少sasl机制。要连接到消息中心,需要将其设置为 PLAIN .
从关于publishkafka的nifi文档来看,似乎可以使用动态属性直接提供kafka设置。您需要将其中一个设置为:

sasl.mechanism=PLAIN

还要确保已经通过指定了jaas文件的路径 -Djava.security.auth.login.config=PATH 在你的nifi配置中。

相关问题