NiFi Confluence 架构注册表异常

NiFi Confluent Schema Registry Exception

我们正在尝试将 NiFi 连接到已设置为使用 Confluent Schema Registry 的 Confluent Kafka 实例,因为我们是 publishing/consuming Avro 格式的消息。

然而,当我们启动我们的 NiFi kafka 处理器时,我们得到以下异常:

Failed to retrieve Schema with subjects array from any of the Confluent Schema Registry URL's 
provided; failure response message: User cannot access the resource

事实证明,安全证书只授予我们访问 Confluent Schema Registry 中特定模式的权限。

我们的证书缺少查询所有架构的能力。这是通过根据 Confluent documentation.

添加 GLOBAL_SUBJECTS_READ 权限来实现的