Nifi consumekafka不接受上行连接
Nifi是一个开源的数据集成工具，用于可视化和自动化数据流程。它提供了一种简单而强大的方式来移动、转换和处理数据，支持从各种来源（如数据库、文件、消息队列等）提取数据，并将其发送到目标系统。
consumekafka是Nifi中的一个处理器（Processor），用于从Apache Kafka消息队列中消费数据。它可以连接到Kafka集群，并从指定的主题（Topic）中读取消息。消费者可以根据需要配置消费的起始偏移量、消费速率等参数。
不接受上行连接意味着consumekafka无法连接到Kafka集群或无法从指定的主题中读取消息。这可能是由于以下原因导致的：
- 网络连接问题：Nifi所在的服务器无法访问Kafka集群，可能是由于网络配置、防火墙设置等问题导致的。解决方法是确保网络连接正常，并且允许Nifi服务器访问Kafka集群。
- Kafka集群配置问题：可能是Kafka集群的配置有误，导致无法接受来自Nifi的连接。检查Kafka集群的配置文件，确保监听地址、端口等配置正确。
- 主题不存在或无权限访问：可能是指定的主题在Kafka集群中不存在，或者Nifi没有足够的权限来读取该主题。确保主题存在，并且Nifi具有读取该主题的权限。
推荐的腾讯云相关产品：腾讯云消息队列 CMQ（Cloud Message Queue），是一种高可用、高可靠、高性能的分布式消息队列服务。您可以使用CMQ来实现类似Kafka的消息队列功能，并与Nifi进行集成。CMQ提供了简单易用的API和控制台，方便您管理和使用消息队列。
腾讯云产品介绍链接地址：腾讯云消息队列 CMQ
相关·内容
1回答
我正在使用consumekafka投票消息，每隔500到10000条记录，而nifi迭代每30秒发生一次。我想消费iteration一旦所有作业完成轮询下一次迭代。但是consumekafka处理器不支持上行连接。 一旦puthdfs成功，我需要使用下一次迭代，在这里我提到了nifi工作流。 工作流程： consumekafka -> mergecontent->convertRecord->updateattribute->puthdfs
浏览 15提问于2020-04-06得票数 0
我有简单的测试设置，在性能测试期间，我注意到nifi以笨拙的方式读取kafka的记录，它不保留顺序。我让consumekafka_20进程连接到日志消息，就像在下面的屏幕上一样
这两个处理器都被配置为只使用一个相同的任务，但是日志消息显示消息。
2021-12-30 17:10:44,612 INFO nifi-0 [Timer-Driven Process Thread-4] o.a.nifi.processors.standard.LogMessage LogMessage[id=0c0931ad-017e-1000-ebfe-53193c54a8b8] caa6dcba-8d44-
浏览 7提问于2021-12-30得票数 0
Kafka主题有大约100个分区，我正在使用Apache nifi ConsumeKafka从那个kafka读取数据，并发送一些其他服务器。 目前这个nifi consumeKafka处理器只有一个消费者，我希望有相似数量的消费者来匹配分区，我没有任何选择来增加消费者的数量，目前我正在添加新的处理器到相同的消费者组，我认为这种方法是正确的。 如何在相同的nifi consumerKafka处理器中增加消费者？
浏览 25提问于2019-12-28得票数 1
用例：我们有为多模式配置的金门卡夫卡大数据适配器。每个模式映射到一个分区，kafka分区器按照定义的映射发布消息。比如schema1=1(Partition#1)，schema2=2 .scheman=n
这样，所有模式的消息都隔离在它们自己的分区中。
问题:给定情况下的，我想配置一个Apachi Nifi节点实例，以处理kafka主题的1个分区。这样，我将配置运行在并行处理100个kafka分区中的100个Nifi实例。
但我看不到在KafkaConsumer中可以指定分区的任何地方
问题：
Apache使用者支持分区配置吗？
如果它不支持，它是否在未来发布的路线图中？
浏览 2提问于2017-11-10得票数 1
回答已采纳
我有一个卡夫卡队列运行和接收信息。我已经使用ConsumeKafka api将Nifi连接到了这个主题(关于kafka)。我想要一个处理器，它可以读取这些消息并对它们应用一些操作。
基于这些需求，什么是最好的方式在内内尼菲？
浏览 1提问于2018-05-17得票数 0
回答已采纳
我是NiFi的新手。我们已经完成了可以使用Kafka消息的设置。在NiFi UI中，我使用ConsumeKafka__10创建了处理器。当消息发布时(不同的流程)，我的处理器能够正确地提取所需的数据/消息。我转到"Data provenance“，可以看到收到了正确的数据。
但是，我想让下一个进程成为某个验证器。这将读取来自consumekafka的流文件并执行基本验证(用户提供的脚本应该是好的)
我们是如何做到这一点的，或者哪个处理器能在这里工作？
还有什么方法可以将flowfile输入格式转换为csv或json格式？
浏览 8提问于2017-11-30得票数 1
上下文：
我有多个应用程序的前提是发布实时消息的企业卡夫卡和安慰队列。信息的体积和速度相当大。从现在起，这些消息被消息处理模块消耗，并存储到实时数据存储的前提下。我们计划在GCP上移动消息处理模块和实时数据存储。
问题陈述：
由于消息处理模块和实时数据存储正在转移到GCP，因此需要发布/推送消息，从“假设的Kafka主题和Solace队列到GCP主题”。
为此，我计划在OnPre前提NiFi集群上编写一个NiFi工作流。如果已经做过类似的尝试，如果有人分享想法，那就太好了。
浏览 1提问于2018-10-06得票数 0
我想在Nifi中使用consumeKafka来使用一个主题。由此，我想拿出一个键值对，并把它放到另一个卡夫卡主题使用PutKafka。我如何实现这一点，并避免基于特定键的重复？
浏览 0提问于2018-05-18得票数 0
像这样的事以前做过吗？如果不是，在让NiFi吞下一条通过WebSocket到达的流时，谷歌FlatBuffers会涉及什么？
(一个简单的TCP流会使它更容易还是更难呢？)
更新
我有一个运行在节点上的C++程序，该程序通过websocket收集数据并通过nanomessage /sub发布数据。C++中的数据看起来像结构，我正在用序列化它。这是一个非常简单的结构，想想csv的记录。我们有一位团队成员希望用NiFi捕获这些数据并将其放到数据库中。
就个人而言，由于Flatbuffers支持将二进制转换为JSON，所以我认为编写一个简短的C#、python、java或javascript程序来
浏览 0提问于2018-07-05得票数 0
我已经开始我的生产者发送数据到Kafka，也开始我的消费者拉相同的data.When，我正在使用消费卡夫卡处理器(kafka版本1.0)在Apache Nifi，我在我的脑海中有几个问题，与Kafka消费者相关。
Q.1)当我第一次启动ConsumeKafka处理器时，如何读取开始消息和当前消息？
Q.2)还有在Kafka中消费者关机的情况下，如何在最后一条消费消息之后阅读消息？
我们如何在使用Apache Nifi的同时实现上述两个功能？
浏览 20提问于2018-07-30得票数 2
回答已采纳
查找最近一周的数据流统计信息(bytesIn、bytesOut)。使用NiFi REST API端点[GET] /nifi-api/processors/{id}，获取了过去五分钟的以下统计信息。是否有任何现有的API端点可以检索一周的数据流统计信息？
{
"id": "1234aa-1234-1f23-1f23-123456ed51f1a",
"status": {
"name": "MyConsumeKafkaProcessor",
"runStatus&
浏览 0提问于2020-07-30得票数 0
我正在使用Kafka和Nifi，当我摄取一个大文件(超过100MB)时。我收到一个TimeOutException错误。卡夫卡不会崩溃。读到这篇文章后，我需要增加以下属性'request.timeout.ms‘，该属性默认设置为30ms。对于需要更长时间才能接收的较大文件，应如何设置此属性？我怎么计算呢？我在生产环境中使用Confluent Kafka 5.3.1。
谢谢
浏览 0提问于2020-05-27得票数 0
我试图使用Apache billion+ (nifi-1.11.4-RC1，OpenJDK 8，RHEL7)从相对较大的主题(超过100个GiB，单个分区)加载消息，但是性能似乎太低了：
ConsumeKafka_2_为每5分钟1248429条消息(276.2 MB)，ConsumeKafkaRecord_2_.为295个批(282.5 MB)也就是说，每秒只有4161条消息(920 KB) 。
kafka-consumer-perf-test.sh (相同节点、相同使用者组和相同主题)的结果更令人印象深刻:每秒263.4 MB (1190937条记录)。与任何合理的间接费用相差太大。
我已经
浏览 3提问于2020-05-30得票数 2
回答已采纳
在设计nifi模板时，我们需要考虑底层集群吗？
下面是我的简单流程
+-----------------+ +---------------+ +-----------------+
| | | | | |
| READ FROM | | MERGE
浏览 11提问于2017-07-07得票数 2
回答已采纳
1回答
不能从NiFi发送给卡夫卡
、、、、
我正在中运行，下面是我的NiFi设置：
关于PublishKafka处理器的详细信息：
关于ConsumeKafka处理器的详细信息：
下面是我的docker文件(注意: 192.168.1.50是我的静态内部主机IP)：
version: '3'
services:
Jenkins:
container_name: Jenkins
restart: on-failure
depends_on:
- NiFi
image: jenkins:latest
ports:
- "3277
浏览 0提问于2018-05-28得票数 0
回答已采纳
我在HDFS中有一个10TB大小的平面文件。我需要将数据写入卡夫卡，然后保存到亚马逊S3。我正在寻找不同的方法来完成这项任务。根据之前提出的问题，我了解到可以通过Nifi或Spark来完成。然而，我不清楚它如何实现。
浏览 0提问于2020-08-04得票数 0
我使用Nifi中的处理器从Kafka获取数据并将其写入文件。脚本在python中。
import json
import java.io
from org.apache.commons.io import IOUtils
from java.nio.charset import StandardCharsets
from org.apache.nifi.processor.io import StreamCallback
class ModJSON(StreamCallback):
def __init__(self):
pass
def process(self,
浏览 2提问于2018-05-17得票数 0
回答已采纳
例如，我在nifi集群中有3个nifi节点。这些节点的示例主机名；
192.168.12.50:8080(小学)
192.168.54.60:8080
192.168.95.70:8080
我知道我可以从所有的nifi节点访问nifi-rest。我有用于从rest获取集群摘要的GetHTTP处理器，并且这个处理器只运行在pimary节点上。我确实将这个处理器的"URL“属性设置为192.168.12.50:8080/nifi-api/controller/cluster.
但是，如果主节点关闭，则将选择新的主节点。因此，我将无法从新的主节点访问192.168.12.
浏览 0提问于2019-01-25得票数 2
回答已采纳
我有以下业务需要。有谁能给我建议一下我应该创建的NiFi WorkFlow吗？通过Kakfa，我获得了作为JSON对象的元数据。这个JSON对象有一个二进制格式的图像或视频。这个二进制文件非常大。2)我需要提取二进制数据并将其发送到HTTP (POST)。
在我看来，我有以下工作流: ConsumeKakfa==>EvaluateJsonPath==>UpdateAttributes=>InvokeHTTP
说明: 1) ConsumeKakfa将接收元数据作为json对象。2) EvaluateJsonPath将提取内容json属性，将图像或视频数据存储为base64。3)
浏览 0提问于2019-01-11得票数 1
回答已采纳
我的任务是创造卡夫卡消费者，应该从卡夫卡提取信息，从其中转换，并存储到蜂巢表。
因此，在卡夫卡主题中，有很多信息是作为json对象的。
我喜欢添加一些字段并将其插入到蜂巢中。
我使用以下Nifi处理器创建流：
ConsumeKafka_2_JoltTransformJSON -用于转换jsonConvertRecord --将json转换为hivePutHiveQL的插入查询
该主题将被充分加载并每天处理大约5Gb的数据。
那么，是否有任何优化我的流的方法(我认为向Hive提供大量的插入查询是个坏主意)？也许使用外部表和putHDFS处理器会更好(以这种方式，如何使用分区并将输入json合并到
浏览 4提问于2020-05-19得票数 1
回答已采纳
我已经在安全模式下运行了一些NiFi独立实例。互相连接vie站点到站点是很好的，我无法连接到自己。
让我们假设一些nifi实例
- https://my-nifi-1.local:9443/nifi
- https://my-nifi-2.local:9443/nifi
- https://my-nifi-3.local:9443/nifi
在https://my-nifi-1.local:9443/nifi和https://my-nifi-2.local:9443/nifi以及https://my-nifi-3.local:9443/nifi之间进行远程连接可以正常工作。
如果我的流通
浏览 10提问于2022-08-04得票数 0
回答已采纳
我简化的Nifi设置是:将ConsumeKafka_2_0处理器转换为PutS3Object处理器。我正在阅读多个主题，主题名包含在S3密钥前缀中。这很好，但是每个FlowFile都存储在一个单独的S3对象中。
我如何在每个主题中积累一些FlowFiles？我遇到了MergeContent处理器，但我不确定它是否满足了我的所有需求。应该编写S3对象
一段时间后，比如说10分钟
在某个大小阈值之后，比如100 say (不管首先发生什么)
按顺序
装箱算法可以将FlowFiles按错误的顺序合并，对吗？碎片整理似乎不起作用，但我不知道，我是否做错了什么。
浏览 0提问于2019-07-16得票数 0
1回答
我正在使用Nifi来管理数据流。我首先使用EvaluateJsonPath ConsumeKafka处理器接收数据，然后使用ReplaceText处理器来获取这个请求。
insert into my_table values('x1','x2','x3');
最后，将此请求发送给PuthiveQl处理器。通过这种方式，我将数据逐行插入到我的Hive表中，运行良好，但这是一种非常糟糕的方法。
我想知道的是如何获得这样的请求
insert into my_table values('x1','x2','x3&#
浏览 2提问于2021-05-19得票数 0
我是Nifi的新手，并试图在下面的流程上做POC。
我从Kakfa主题获得XML消息。我需要使用XML消息，从XML元素中获取少量的属性和数据( GZIP压缩格式)，GZIP解压缩数据(再次是MySQL )，然后加载到XML。我正在尝试这个，却被困在了下面的步子里。
(1)ConsumeKafka→(2)EvaluateXPath (flowfile-attribute =i)将几个XML元素设置为流文件-属性，这是非常有用的。(3)使用XPATH表达式= string(//ABC/ data )获取gzip数据的EvaluateXPath (flowfile-content =gzip数据)
浏览 3提问于2019-12-01得票数 0
1回答
服务器上有NiFi和NiFi注册表，这是没有连接的，我不能通过本地NiFi instance.But连接到NiFi注册表，我可以通过远程桌面访问NiFi和NiFi注册表。 在我的本地开发系统上安装了另一个版本的NiFi和NiFi注册表。有没有办法离线更新(同步)远程NiFi注册表流并将新的更新应用到远程NiFi？ ?
浏览 19提问于2020-11-07得票数 1
我正在编写两个数据流，一个是带有HandleHttpRequest/Response处理器的get服务，在收到通知后，应该使用GetFTP触发一个单独的流，以便从FTP目录中获取文件。
我尝试过使用等待/通知处理器来同步这两个进程，但是GetFTP不允许传入连接，所以我无法连接到等待进程。
你知道我该怎么做吗？
浏览 1提问于2017-08-25得票数 0
我们有一个使用ssl配置的Teiid12.3服务器正在运行。我们能够使用像pentaho etl、squirrel client、Tableau等工具连接这个teiid服务器，我们正在使用trustore文件连接这些工具。但是我们无法连接Apache NIfi中的Teiid服务器。我们尝试了以下方法来包括信任-
在运行的nifi.bat中添加trustore
- set JAVA\_ARGS=`-Dorg.apache.nifi.bootstrap.config.log.dir=%NIFI_LOG_DIR%` `-Dorg.apache.nifi.bootstrap.config.
浏览 5提问于2020-04-28得票数 0
1回答
我正在尝试使用带有GetRethinDB处理器的apache nifi从我本地的rethinkdb中获取一些数据。它向我显示配置错误，即上游连接设置无效。有人能帮我理解它的含义和克服它的方法吗？有没有其他处理器可以和它一起使用？
谢谢
尼尔
浏览 0提问于2017-11-01得票数 0
我已成功安装nifi安全集群，但无法启动错误的nifi.app.log
错误main org.apache.nifi.NiFi无法启动NiFi，原因是java.net.ConnectException:连接被拒绝(连接被拒绝) 2017-09-20 18:39:03,405信息-1\f25 Thread-1 \f6 org.apache.nifi.NiFi -1\f6开始关闭Jetty web -1\f6服务器...2017-09-20 18:39:03,406信息线程-1 org.apache.nifi.NiFi Jetty web服务器关闭完成(好的或不好的)。
浏览 0提问于2017-09-20得票数 0
我需要用JSON向发送以下GET请求
GET /path/to/data
{
"abcd": [
"a1",
"a2"
]
}
在URL中以这样的方式编码：.
我试图通过以下两个NiFi流来完成这个请求：
GenerateFlowFile -> ReplaceText -> UpdateAttribute -> InvokeHTTP -> PutFile
GenerateFlowFile -> UpdateAtribute -> AttributeToJSON -> Invok
浏览 8提问于2018-11-14得票数 1
2回答
我正在尝试连接到Oracle Cloud上的Oracle数据库，这需要使用SSL wallet + TNS名称。我已经在docker中设置了Nifi，但是我无法连接到数据库。我已经使用SSL钱包测试了与数据库的连接，并且能够从主机连接，但不能从Nifi连接。 我遵循了https://docs.oracle.com/en/cloud/paas/autonomous-database/adbsa/connect-jdbc-thin-wallet.html的指导 Nifi中DB连接池的设置如下所示： Nifi DBCP settings 但是，我得到的错误是它无法解析TNS名称。Error Mes
浏览 49提问于2021-01-14得票数 1
回答已采纳
我设置了一个httpListen处理器来监听端口8080。当我在8080上使用postman连接到本地主机时，它工作得很好，但是外部连接被拒绝了。我认为可能是必须配置为所有外部连接的nifi.properties文件。
从与nifi服务器相同的网络中的端点，我能够平平NIFI服务器，但是运行命令wget http://<private_NIFI_IP>:8080/contentListener却拒绝连接。
在NIFI服务器上，我运行了相同的命令，并收到了405错误:不允许的方法。
浏览 12提问于2022-01-20得票数 0
我最近尝试在Ubuntu 20.04上安装Apache Nifi 1.13.2。(Java版本: OpenJDK 11。)默认的HTTP属性部分允许它在端口8080上使用nifi.properties正常运行，但如果我将其更改为任何其他端口，它将失败。 例如，如果我将nifi.web.http.port更改为9300并尝试连接到localhost:9300/nifi，它就会拒绝连接。如果我将nifi.web.https.port更改为9443，将nifi.web.https.host更改为127.0.0.1，并对nifi.remote.input.secure (更改为true)和nifi.
浏览 199提问于2021-05-02得票数 0
我正在安装一个带有嵌入式动物园管理员的三节点非安全nifi集群(1.5)。
安装已经完成，集群启动和选举已经完成，没有任何明显的问题。
然而，当我击中gui时，我看到了以下情况：
javax.ws.rs.ProcessingException: java.net.ConnectException:连接拒绝(连接拒绝)
在nifi-apps.log中有：
2018-03-07 14:41:37,857 WARN [Replicate Request Thread-7] o.a.n.c.c.h.r.ThreadPoolRequestReplicator Failed to replicate re
浏览 0提问于2018-03-07得票数 1
回答已采纳
我在虚拟机中安装了nifi-1.16.2虚拟机的ip是192.168.1.115，我的机器用来连接nifi can ping到192.168.1.115
我改变了nifi.properties
nifi.web.https.host=192.168.1.115
nifi.web.https.port=9102
然后我用"sh nifi.sh start“启动nifi。
现在我的机器可以使用"telnet 192.168.1.115 9102"，但我不能使用浏览器访问网址"192.168.1.115:9102/nifi“。
浏览 3提问于2022-06-14得票数 0
我试图使用"org.apache.kafka.clients.NetworkClient ConsumeKafka_2_6处理器(NiFi版本1.12.1).In ConsumeKafka处理器使用NiFi ConsumeKafka_2_6 processor (nifi版本1.12.1)使用来自Amazon上的kafka主题(Kafka version 2.2.1)中的消息。我收到的警告是:nifi Consumer =console-consumer can 34567-5，groupId=nifi-consumer broker localhost:9092 (id：-齿条1:
浏览 4提问于2021-01-05得票数 1
回答已采纳
我有一个运行nifi (--name nifi)的容器暴露了8080端口，另一个运行nifi注册表(--name nifireg)的容器暴露了端口10808。我可以访问这两个UI，并且能够通过使用注册中心容器的IP (172.17.0.5)将nifi连接到注册中心服务中的注册中心。这些容器也位于一个名为nifi-net的docker网络上。我的问题是，当使用容器名称时，注册表客户端无法与注册表对话。
从nifi我可以通过容器IP和名称(ping nifireg)来ping，所以有一定程度的连通性。但是，如果我将注册表客户端更改为指向http://nifireg:180880，甚至是http:/
浏览 4提问于2021-10-27得票数 0
1回答
看上去是个成功的开端之后：
nifi run
INFO [main] org.apache.nifi.bootstrap.Command Starting Apache NiFi...
...
INFO [main] org.apache.nifi.bootstrap.Command Launched Apache NiFi with Process ID 14532
我仍然不能访问(默认)指定地址127.0.0.1:8443/nifi/的应用程序。
通过cat nifi-app.log在自制安装目录中查看应用程序日志，我可以看到它似乎再次可用：
INFO [main] org.apache.
浏览 26提问于2022-11-07得票数 -1
1回答
使用和上的博客文章，当两者位于同一台机器上时，我可以从NiFi流传输到Spark。现在，我试图从一个EC2实例上的NiFi流到同一子网和安全组中的一个EMR集群，但遇到了问题。EMR Core机器报告的特定错误是
Failed to receive data from NiFi
java.net.ConnectException: Connection refused
at sun.nio.ch.Net.connect0(Native Method)
at sun.nio.ch.Net.connect(Net.java:454)
at sun.nio.ch.Net.co
浏览 1提问于2017-01-13得票数 3
回答已采纳
1回答
我在nifi lib文件夹中添加了一些jar文件，以允许我连接hive，但不幸的是，nifi应用程序没有在web上运行，然后我删除了所有新的jar文件，但是问题没有解决，我一直收到以下错误(NIFIVersion1.15.0)
由于org.apache.nifi.NiFi : org/apache/ NiFi /processor/DataUnit导致主要nifi启动失败
浏览 4提问于2021-12-28得票数 0
使用Hbase处理Nifi。在这篇文章中，我从Hbase获取数据，使用Gethbase处理器并将数据发送到Nifi.But中的Putfile处理器。我在Nifi .Any建议中收到错误消息“由于java net连接异常，无法从Hbase接收数据:连接被拒绝”请
浏览 1提问于2016-05-04得票数 0
是否可以将Nifi中的入站TCP连接数量扩展到数万个？使用TCP连接扩展NIFI :文档规定最大设置为2。
我们期望处理10-25,000个长时间运行的TCP连接(最大连接持续时间为4小时)。部署多个冗余NIFI集群来处理负载不是问题。
该域是带有TCP设备的IoT。设备只能通过TCP发送消息。每台设备每2分钟发送一条消息。我们正在考虑迁移到AWS上的NIFI集群/容器化解决方案，如果它能够扩展以处理我们的连接负载。
是否有类似的挑战、经历或变通方法？
谢谢!
浏览 0提问于2019-11-18得票数 1
我想知道NiFi中的总队列大小何时超过某个特定值。我尝试使用NiFi工具包，但我无法在其中找到表示总队列大小的任何内容。 我一直在尝试this，它应该允许我通过API访问NiFi中一组进程中的连接。但是，我无法从NiFi成功连接到该接口。 当我尝试在没有凭据的情况下连接到API时，我在NiFi中得到以下错误。 Unknown user with identity 'anonymous'. Contact the system administrator. 我相信我能够通过REST API查看队列大小，但是为了做到这一点，我需要使用OAuth和Keycloak进行身份验证，我不
浏览 23提问于2020-09-08得票数 0
我想用NiFi来连接ADLS。我的场景是这样的: Nifi在windows机器上安装并运行。现在我想把数据从windows本地目录移到ADLS。我现在不使用任何hadoop组件。我又想把数据从ADLS移动到Azure中的SQL server。如何将运行Nifi的windows连接到ADLS？我找到的所有指令都是配置core-site.xml文件并将jars放到Nifi特定的文件夹中。但是，由于我没有运行Hadoop (所以我没有core-site.xml文件)，在这种情况下，我如何将Nifi连接到ADLS？
有没有人能分享一下如何做到这一点呢？
提前谢谢。
浏览 0提问于2018-09-27得票数 1
我正在尝试保护Kubernetes集群中的Nifi，在Traefik代理之后。两者都在K8S中作为服务运行。Traefik使用公共证书进行保护。我希望它将调用重定向到nifi，同时保护Traefik (作为入口控制器)和后端pod: Nifi之间的通信。
看起来安全配置应该在我的入口YAML描述符中。看起来我应该颁发一个CA根来生成Nifi自签名证书，并在Traefik中加载这个CA根，这样它就可以在与Nifi握手时验证Nifi发送的证书。
但是..。我不知道1)这是不是好的方法，2)我如何才能生成我的商店(信任，...)对于使用CA根的NiFi，3)我应该如何设置我的YAML (似乎不支持i
浏览 2提问于2018-04-13得票数 1
我无法使用nifi-1.8.0连接apache drill，但可以使用nifi-1.7.1连接。
我正在使用jdbc通过ExecuteSql连接字符串来连接apache drill。在nifi-1.8.0的情况下，poolableExcecption即将到来。
Unable to execute SQL select query SELECT * from test.wellRecords due to org.apache.nifi.processor.exception.ProcessException: java.sql.SQLException: Cannot create Pool
浏览 0提问于2019-02-12得票数 0
1回答
我有一个6节点集群，在公告中的大部分时间我看到了这条消息
Failed to communicate with Peer nifi-4.nifi-hs:8443 when load balancing data for Connection with ID 4fc4e9f5-017b-1000-0000-00005d8f751e due to java.net.SocketTimeoutException: Timed out waiting for Peer nifi-4.nifi-hs:8443 to acknowledge Protocol Version
有关财产如下：
nifi.we
浏览 1提问于2022-02-15得票数 3
我让ApacheApache1.2.0运行在一个名为NiFi的远程VM上。以下是运行JVM的列表：
bash-4.2$ ./jps
1043 RunNiFi
1062 NiFi
14810 Jps
在我的本地Windows 7机器上，我有jdk1.8.0_121，我正在尝试将实用程序连接到'NiFi‘JVM。
一些事实：
我希望监视的远程RHEL JVM与用户“nifi”一起运行
，因为我是一个'sudoer'，所以我使用自己的用户名'ojoqcu‘到SSH(通过Putty)到远程VM，然后使用'sudo su -，su nifi’或简单的
浏览 0提问于2017-06-21得票数 0
1回答
我有多个独立的NiFi实例(大约。10)我希望使用RPG (站点到站点)将数据发送到NiFi集群(3个NiFi实例)。但是，从独立实例到集群的流程似乎很慢。
这样做对吗？
NiFi允许多少个站点到站点的连接？
对于站点到站点的NiFi数据流有什么最佳实践吗？
浏览 1提问于2018-10-23得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
云直播活动推荐
腾讯云开发者
