I have a usecase where i need to ingest data from Oracle DB and send it to elastic search
i have written a config file which is executing fine when connection is ok. but today when i ran it somehow password got wrong and due to that connection failure logstash was restarting itself continuously.
config file :
input {
jdbc {
jdbc_validate_connection => true
connection_retry_attempts => 2
connection_retry_attempts_wait_time => 60
jdbc_connection_string => 'jdbc:oracle:thin:@<host>:<port>/<service name>'
jdbc_user => '<user>'
jdbc_password=>'<DBpassword>'
jdbc_driver_library=>'<absolute path to ojdbc8.jar>'
jdbc_driver_class=>'Java::oracle.jdbc.OracleDriver'
statement => 'select * from mytable'
last_run_metadata_path=>'<path to yml file>'
}
}
output {
stdout {
codec => json_lines
}
}
Even if i gave wrong DB host to test the retry attempts, it seems logstash is ignoring all and restating itself and getting stuck in an infinite loop.
log :
[Error] [logstash.inputs.jdbc ] Unable to connect to database. Tried 1 times{:error_message=>"Java::JavaSql::SqlRecoverableException: IO Error: Unknown host specified}
[logstash.javapipeline ] A plugin had an unrecoverable error. Will restart this plugin.
Pipeline_id:main
Plugin: <Logstash::
Logstash version 7.2.0
plugin version used
logstash-input-jdbc (4.3.13)
logstash-filter-jdbc-static (1.0.6)
Can anyone suggest what i am doing wrong