【问题标题】:Configuring Apache NiFi for sending messages to Message Hub配置 Apache NiFi 以将消息发送到 Message Hub
【发布时间】:2018-06-23 22:15:17
【问题描述】:

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

我已输入这些值以供参考

我在 Ubuntu 18.04 上这样做

【问题讨论】:

标签: ibm-cloud apache-nifi message-hub


【解决方案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 section 中所述。 /org.apache.nifi.processors.kafka.pubsub.PublishKafka_0_11/additionalDetails.html

    您还可以查看How do you connect NIFI to IBM MessageHub through PublishKafka processor? 获取 JAAS 文件示例。

【讨论】:

  • thanx michael 对于您的及时回复....我在哪里设置这个 sasl.mechanism=PLAIN 在 nifi...我无法找到放置这个的地方
  • 点击“配置处理器”窗口右上角的“+”图标添加自定义属性
猜你喜欢
  • 1970-01-01
  • 1970-01-01
  • 2021-01-14
  • 2022-01-12
  • 2013-12-25
  • 2019-07-22
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
相关资源
最近更新 更多