Nifi Redis Sentinel 集成

如何解决Nifi Redis Sentinel 集成

我正在尝试以哨兵模式将 Nifi 与 Redis 集成，如本教程中所述：

https://bryanbende.com/development/2017/10/09/apache-nifi-redis-integration

我的 Redis 集群有 2 个节点，运行在 6391 端口，还有 2 个哨兵，运行在 6392 端口。似乎工作正常：

127.0.0.1:6392> sentinel master mymaster
 1) "name"
 2) "mymaster"
 3) "ip"
 4) "192.168.50.5"
 5) "port"
 6) "6391"
 7) "runid"
 8) "d8adfb30d836ad305b96d887dfe2beb74c435305"
 9) "flags"
10) "master"
11) "link-pending-commands"
12) "0"
13) "link-refcount"
14) "1"
15) "last-ping-sent"
16) "0"
17) "last-ok-ping-reply"
18) "626"
19) "last-ping-reply"
20) "626"
21) "down-after-milliseconds"
22) "5000"
23) "info-refresh"
24) "5796"
25) "role-reported"
26) "master"
27) "role-reported-time"
28) "56761859"
29) "config-epoch"
30) "0"
31) "num-slaves"
32) "1"
33) "num-other-sentinels"
34) "1"

Nifi 数据流：

Redis 连接池：

当我运行数据流时，出现此错误：

PutdistributedMapCache[id=08e39b65-0176-1000-0000-0000185bd23e] 失败 由于所有哨兵都关闭而处理会话，无法确定在哪里 mymaster master 正在运行吗...;处理器管理让步 1 秒：redis.clients.jedis.exceptions.JedisConnectionException： 所有哨兵都倒下，无法确定mymaster master在哪里 运行...

解决方法

经过无数小时的痛苦，我终于找到了一种解决方法，即禁用哨兵中的密码。指定的密码是redis的，不是sentinel