У меня простая конфигурация logstash:
input {
jdbc {
jdbc_driver_library => "..\sqljdbc_6.0\enu\jre8\sqljdbc42.jar"
jdbc_connection_string => "jdbc:sqlserver:/server:1433;databaseName=DBNAME;integratedSecurity=true;"
jdbc_driver_class => "com.microsoft.sqlserver.jdbc.SQLServerDriver"
statement => "select top(10) eventdata from TABLE"
schedule => "*/20 * * * * *"
}
}
output {
jdbc {
connection_string => "jdbc:sqlserver://DBSERVER:1433;databaseName=DBNAME;integratedSecurity=true;"
driver_jar_path =>"..\sqljdbc_6.0\enu\jre8\sqljdbc42.jar"
statement => ["insert into TABLENAME(t) values(?)", "@timestamp"]
}
}
Входная часть отлично работает, считывая значения из БД.Однако при попытке вывода в другую базу данных я получаю следующую ошибку:
Java::JavaLang::IllegalAccessError: com/microsoft/sqlserver/jdbc/StreamError
2076 com.microsoft.sqlserver.jdbc.TDSTokenHandler.onError(com/microsoft/sqlserver/jdbc/tdsparser.java:222)
2076 com.microsoft.sqlserver.jdbc.TDSParser.parse(com/microsoft/sqlserver/jdbc/tdsparser.java:83)
Я использую logstash 6.5, sqljdbc 4.2 и OpenJDK (Amazon Corretto 8.2 JRE)
КогдаЯ изменяю выходной конфиг, чтобы вывести в файл или консоль, он работает нормально.
Любая помощь будет оценена.