【发布时间】:2018-06-23 22:15:17
【问题描述】:
我需要设置哪些属性才能开始将消息从 Apache NiFi PublishKafka 处理器发送到 IBM Cloud 中的 Message Hub?
我已输入这些值以供参考
我在 Ubuntu 18.04 上这样做
【问题讨论】:
标签: ibm-cloud apache-nifi message-hub
我需要设置哪些属性才能开始将消息从 Apache NiFi PublishKafka 处理器发送到 IBM Cloud 中的 Message Hub?
我已输入这些值以供参考
我在 Ubuntu 18.04 上这样做
【问题讨论】:
标签: ibm-cloud apache-nifi message-hub
您需要设置以下动态属性:
sasl.mechanism=PLAIN
您还需要指定您的 SASL 凭据,使用消息中心实例中的用户名/密码:
使用 PublishKafka_1_0,您还需要指定另一个动态属性:
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="USERNAME" password="PASSWORD";
使用 PublishKafka_0_11,您需要创建一个 JAAS 文件,如 NiFi 文档中的 SASL PLAIN section 中所述。 /org.apache.nifi.processors.kafka.pubsub.PublishKafka_0_11/additionalDetails.html
您还可以查看How do you connect NIFI to IBM MessageHub through PublishKafka processor? 获取 JAAS 文件示例。
【讨论】: