Jdbc_streaming filter parameters not working

Elastic Stack Logstash
1

Hi I am unable to use jdbc_streaming filter parameters in the query.

	jdbc_streaming {
		jdbc_driver_library => "/home/titech/Desktop/jar/mysql-connector-java-5.1.46.jar"
		jdbc_driver_class => "com.mysql.jdbc.Driver"
		jdbc_connection_string => "jdbc:mysql://localhost:3306/sys"
		jdbc_user => "root"
		jdbc_password => "titech!@#"
		parameters => { "auditId" => 26}
		statement => "SELECT * FROM sys.rcyc_audit where audit_id= :auditId ;" 		
		target => "port_update_audit_id"
	}

Actual value for auditId is coming from event but since it was not working, for debugging, I hardcoded the value 26, even then it is not taking the value.

when I run the sql query "SELECT * FROM sys.rcyc_audit where audit_id=26;" directly it is working.
but when I use parameter it throws exceptions [0] "_jdbcstreamingdefaultsused"

Please advice.

2

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.