我已经在Docker中独立保护了NiFi 1.12.1,运行一切正常。我很乐意使用站点到站点的远程处理器,站点到站点的Nifi公告转发,调用Nifi API进行自我监控等等。我通过证书登录。到目前为止一切都很好。
当我试图使用NiFi注册表时,问题出现了。我可以访问两个实例:安全和不安全。
无论我指定了什么确切的格式(FQDN,只是一个名称,带/nifi-registry或不带),当我试图从NiFi访问(例如,通过导入进程组)NiFi注册表时,o.a.n.w.a.config.nificoreExceptionMapper org.apache.NiFi.web.nificoreException失败:无法获得buckets列表:java.net.ConnectException:Connection Delection(Connection Delection)。返回冲突响应。
。在日志中只有这个消息和大量的堆栈跟踪,仅此而已。
我检查了所有证书,它们似乎都正常(证书路径,证书既适用于clientAuth,也适用于serverAuth)。我甚至自己用它们登录NiFi...最令我惊讶的是,它适用于站点到站点协议、API调用等,但不适用于NiFi注册中心。
你难道不知道什么可能是个问题吗?或者有什么想法要检查什么吗?
#Safe NiFi - the one I am troubleshooting
https://<my FQDN>:8443/nifi-api/flow/registries
#Safe NiFi Registry (another container) - the one I am trying connect to
https://<my FQDN>:18443/nifi-registry-api/buckets
#Unsafe NiFi (another container) - just for test
http://<my FQDN>:28080/nifi-api/flow/registries
#Unsafe NiFi Registry (another container) - just for test
http://<my FQDN>:38080/nifi-registry-api/buckets
我正在尝试使用Hortonworks Schema注册表反序列化一些由Nifi序列化的Kafka消息 在Nifi端用作RecordWriter的处理器:AvroRecordSetWriter 我能够在其他Nifi kafka消费者中反序列化这些消息。但是我正在尝试使用Kafka代码从我的Flink应用程序中反序列化它们。 我的Flink应用程序的Kafka反序列化程序处理程序中有以下内容: 这是用
我们正在尝试将NiFi连接到合流Kafka实例,该实例已设置为在以Avro格式发布/使用消息时使用合流模式注册表。 但是,当我们启动NiFi kafka处理器时,我们会遇到以下异常:
我试图用MergeContent处理器在磁盘上写一个文件,但是我得到的文件大小变化很大-从一行到806行不等。我多次重复这个过程,试图找出Apache NIFi MergeContent处理器中所述的换行demarcator--将demarcator设置为新行,我得到了真正随机大小的文件。 我需要设置哪些参数才能遵守以下逻辑? 建立单个bin 将所有流文件路由到bin 如果len(bin)>x或b
我有一个Docker1.12在CentOS上运行。我正在尝试添加不安全的注册表到它和文件中提到的东西只是不工作。系统使用,因此我创建了文件。 加载后台进程并重新启动docker服务后,systemd显示环境变量在那里 但是当我运行时,我没有看到添加了不安全的注册表 将图像推送到失败,原因是 有什么可以做的吗?我是不是漏掉了什么? 更新 之后,不安全的注册表开始工作。
我安装了docker工具箱,我正在尝试连接到我的私有注册表。 我将以下内容添加到 我可以成功登录注册表。但是当我尝试从注册表拉/推到注册表时,我收到以下错误。 任何帮助都将不胜感激。谢谢
我目前在让NiFi和Zookeeper使用Kerberos进行身份验证时遇到了一些问题。任何帮助都将不胜感激。 当我尝试用Kerberos配置启动NiFI时,它只是在启动过程中关闭。 我正在使用外部ZooGuard集群(不是嵌入式集群)。根据NiFi管理指南,我已将以下内容添加到我的配置文件中: $NIFI\U HOME/conf/bootstrap。形态: $NIFI_HOME/conf/nif