我正在尝试将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
1条答案
按热度按时间2lpgd9681#
从您提供的配置来看,似乎缺少sasl机制。要连接到消息中心,需要将其设置为
PLAIN
.从关于publishkafka的nifi文档来看,似乎可以使用动态属性直接提供kafka设置。您需要将其中一个设置为:
还要确保已经通过指定了jaas文件的路径
-Djava.security.auth.login.config=PATH
在你的nifi配置中。