Соединение Logstash 6.5 и asticsearch 6.5 с использованием SSL
Я пытаюсь подключить push-данные из MySQL к asticsearch, используя logstash через SSL. Elasticsearch и mysql находятся в облаке IBM. Файл конфигурации logstash настроен
input {
jdbc {
jdbc_validate_connection => true
jdbc_connection_string => "jdbc:mysql://<host>:<port>/<schema>?autoReconnect=true&useSSL=false"
jdbc_user => "test"
jdbc_password => "pwd"
jdbc_driver_library => "D:/mysql-connector-java-8.0.12/mysql-connector-java-8.0.12.jar"
jdbc_driver_class => "Java::com.mysql.cj.jdbc.Driver"
jdbc_paging_enabled => true
jdbc_page_size => 25000
type => "location"
statement => "SELECT ENTITY_NAME,
SECONDARY_ENTITY_NAME,
KEYWORD,
DESCRIPTION,
LATITUDE,
LONGITUDE,
MAP_URL,
SHORT_URL,
REF_URL,
LANGUAGES
FROM LOCATION"
}
}
filter{
mutate{
rename => {
"entity_name" => "ENTITY_NAME"
"secondary_entity_name" => "SECONDARY_ENTITY_NAME"
"keyword" => "KEYWORD"
"description" => "DESCRIPTION"
"map_url" =>"MAP_URL"
"short_url" => "SHORT_URL"
"ref_url" =>"REF_URL"
"languages"=>"LANGUAGES"
}
}
if [latitude] and [longitude]!="" {
mutate {
rename => {
"latitude" => "[LAT_LON][lat]"
"longitude" => "[LAT_LON][lon]"
}
}
}
}
output {
elasticsearch {
action=>"index"
hosts=>["https://<id>:<pwd>@<hostname>:<pot>/"]
index=>"test_location"
document_type=>"%{type}"
ssl=>true
ssl_certificate_verification=>true
cacert=>"D:/Data/Logstash-ES-6.5-Mapping/ca_logstash.cer"
}
stdout {}
}
Я получаю ошибку как
[ОШИБКА][logstash.pipeline ] Ошибка регистрации плагина {:pipeline_id=>"main",:plugin=>"#",:error=>"Данные сертификата не найдены",:thread=>"#"}
Я знаю, что это не в состоянии получить данные сертификата. пытался дать точный путь, который тоже не работает?
Настройки конфигурации правильные?