如何通过PublishKafka处理器将NIFI连接到IBM MessageHub? [英] How do you connect NIFI to IBM MessageHub through PublishKafka processor?
问题描述
我正在尝试将NIFI连接到IBM MessageHub,但是没有任何连接可用.
I am trying to connect NIFI to IBM MessageHub but I am not getting any connection working.
有人有一个有效的示例来说明如何配置它吗?
Does anyone have a working example on how to configure it?
我在公告板上收到超时异常.
I get a timeout exception in the bulletinboard.
我已经配置了 PublishKafka_0_11 1.4.0处理器. 将其配置为SASL_SSL,添加了标准ssl上下文服务,添加了jaas.conf
I have configured a PublishKafka_0_11 1.4.0 processor. Configured it as SASL_SSL, added standard ssl context service, added the jaas.conf
KafkaClient {
org.apache.kafka.common.security.plain.PlainLoginModule required
serviceName="Message Hub-bq"
username="xxxxxx"
password="xxxxxx";
};
在日志中,我得到:
2017-11-24 13:47:01,407信息[kafka-producer-network-thread | producer-1] o.a.k.common.network.SaslChannelBuilder无法创建频道,原因是 org.apache.kafka.common.KafkaException:无法配置SaslClientAuthenticator
2017-11-24 13:47:01,407 INFO [kafka-producer-network-thread | producer-1] o.a.k.common.network.SaslChannelBuilder Failed to create channel due to org.apache.kafka.common.KafkaException: Failed to configure SaslClientAuthenticator
推荐答案
查看您提供的配置,似乎您缺少了SASL机制.要连接到消息中心,需要将其设置为PLAIN
.
Looking at the configuration you provided, it looks like you're missing the SASL mechanism. To connect to Message Hub this needs to be set to PLAIN
.
From the NiFi docs about PublishKafka, it looks like you can directly provide Kafka setting using Dynamic Properties. You will need to set one of these to:
sasl.mechanism=PLAIN
还请确保已在NiFi配置中通过-Djava.security.auth.login.config=PATH
指定了JAAS文件的路径.
Also be sure you've specified the path to the JAAS file via -Djava.security.auth.login.config=PATH
in your NiFi configuration.
这篇关于如何通过PublishKafka处理器将NIFI连接到IBM MessageHub?的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!