1

我正在尝试将 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] Oakcommon.network.SaslChannelBuilder 由于 org.apache.kafka.common.KafkaException 创建通道失败：无法配置 SaslClientAuthenticator

在此处输入图像描述

4

1 回答 1

1

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

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

sasl.mechanism=PLAIN

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

于 2017-11-24T14:59:43.303 回答