кросс-кластерная репликация opensearch не работает
Я пытаюсь настроить кросс-кластерную репликацию в opensearch 1.3.1 Ниже приведена проблема, с которой я сталкиваюсь при запуске репликации в следящем кластере opensearch. Я отключил модуль безопасности с помощью конфигурации yml.
Я вижу, что сначала проверка разрешений для индекса прошла успешно, а позже я вижу, что есть проблема с рукопожатием, и это связано с разрешениями. Подскажите, что здесь можно исправить.
Шаг -1 -> настройка CCR
curl --location --request PUT 'http://localhost:9401/_cluster/settings?pretty' \
--header 'Content-Type: application/json' \
--data-raw '{
"persistent": {
"cluster": {
"remote": {
"leader-connection": {
"seeds": ["localhost:9400"]
}
}
}
}
}'
шаг -2 - начать репликацию
curl --location --request PUT 'http://localhost:9401/_plugins/_replication/alert_tags/_start?pretty' \
--header 'Content-Type: application/json' \
--data-raw '{
"leader_alias": "leader-connection",
"leader_index": "alert_tags"
}'
журналы наблюдались:
[2022-04-08T18:16:49,619][INFO ][o.o.r.a.i.TransportReplicateIndexAction] [bkp-node-1] Setting-up replication for leader-connection:alert_tags -> alert_tags
[2022-04-08T18:16:49,619][INFO ][o.o.r.a.s.TransportValidatePermissionsAction] [bkp-node-1] **Replication setup - Permissions validation successful for Index - alert_tags and role null**
[2022-04-08T18:16:49,619][INFO ][o.o.r.a.s.TransportSetupChecksAction] [bkp-node-1] Permissions validation successful for User [local:my-bkp, resource:alert_tags]
[2022-04-08T18:17:19,629][WARN ][o.o.t.SniffConnectionStrategy] [bkp-node-1] fetching nodes from external cluster [leader-connection] failed
org.opensearch.transport.ConnectTransportException: [][127.0.0.1:9400] handshake_timeout[30s]
at org.opensearch.transport.TransportHandshaker.lambda$sendHandshake$1(TransportHandshaker.java:99) ~[opensearch-1.3.1.jar:1.3.1]
at org.opensearch.common.util.concurrent.ThreadContext$ContextPreservingRunnable.run(ThreadContext.java:733) ~[opensearch-1.3.1.jar:1.3.1]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?]
at java.lang.Thread.run(Thread.java:829) [?:?]
[2022-04-08T18:17:19,633][ERROR][o.o.r.a.s.TransportSetupChecksAction] [bkp-node-1] **Permissions validation failed for User** [connection:leader-connection, resource:alert_tags] with ConnectTransportException[[][127.0.0.1:9400] handshake_timeout[30s]]
at org.opensearch.transport.TransportHandshaker.lambda$sendHandshake$1(TransportHandshaker.java:99)
at org.opensearch.common.util.concurrent.ThreadContext$ContextPreservingRunnable.run(ThreadContext.java:733)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:829)
[2022-04-08T18:17:19,634][WARN ][r.suppressed ] [bkp-node-1] path: /_plugins/_replication/alert_tags/_start, params: {pretty=, index=alert_tags}
org.opensearch.transport.ConnectTransportException: [][127.0.0.1:9400] handshake_timeout[30s]
at org.opensearch.transport.TransportHandshaker.lambda$sendHandshake$1(TransportHandshaker.java:99) ~[opensearch-1.3.1.jar:1.3.1]
at org.opensearch.common.util.concurrent.ThreadContext$ContextPreservingRunnable.run(ThreadContext.java:733) ~[opensearch-1.3.1.jar:1.3.1]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[?:?]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[?:?]
at java.lang.Thread.run(Thread.java:829) ~[?:?]