如何通过 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

推荐答案

查看您提供的配置，您似乎缺少 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.

来自关于 PublishKafka，看起来您可以使用动态属性直接提供Kafka设置.您需要将其中一项设置为:

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屋！