如何通过 PublishKafka 处理器将 NIFI 连接到 IBM MessageHub？

Question

我正在尝试将 NIFI 连接到 IBM MessageHub，但我无法建立任何连接。

有人有关于如何配置它的工作示例吗？

我在公告栏中收到超时异常。

我配置了 PublishKafka_0_11 1.4.0 处理器。将其配置为 SASL_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:01,407 信息 [kafka-producer-network-thread | producer-1] o.a.k.common.network.SaslChannelBuilder 由于以下原因无法创建频道 org.apache.kafka.common.KafkaException: 配置 SaslClientAuthenticator 失败

Answer 1

查看您提供的配置，您似乎缺少 SASL 机制。要连接到 Message Hub，需要将其设置为 PLAIN。

从关于 PublishKafka 的 NiFi 文档来看，您似乎可以使用动态属性直接提供 Kafka 设置。您需要将其中一项设置为：

sasl.mechanism=PLAIN

还要确保您已经在 NiFi 配置中通过 -Djava.security.auth.login.config=PATH 指定了 JAAS 文件的路径。

如何通过 PublishKafka 处理器将 NIFI 连接到 IBM MessageHub？

How do you connect NIFI to IBM MessageHub through PublishKafka processor?

apache-kafka

apache-nifi

message-hub

ibm-cloud