ibm-cloud - 配置 Apache NiFi 以将消息发送到 Message Hub

Question

我需要设置哪些属性才能开始将消息从 Apache NiFiPublishKafka处理器发送到 IBM Cloud 中的 Message Hub？

我已输入这些值以供参考

我在 Ubuntu 18.04 上这样做

Answer 1

您需要设置以下动态属性：

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 部分所述。/org.apache.nifi.processors.kafka.pubsub.PublishKafka_0_11/additionalDetails.html

  您还可以查看如何通过 PublishKafka 处理器将 NIFI 连接到 IBM MessageHub？对于 JAAS 文件示例。