Я пытаюсь интегрировать 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"
Нифи поток данных:
Пул соединений Redis:
Когда я запускаю поток данных, я получаю эту ошибку:
Ошибка PutDistributedMapCache[id=08e39b65-0176-1000-0000-0000185bd23e] для обработки сеанса из-за того, что все часовые отключены, не могу определить, где моймастер-мастер работает...; Процессор административно уступлен на 1 секунду: redis.clients.jedis.exceptions.JedisConnectionException: Все стражи сбиты, не могу определить, где мой мастер-мастер. бег...
После бесчисленных часов страданий я наконец нашел обходной путь, отключив пароль в часовом. Пароль, который нужно указать, это пароль redis, а не sentinel.