When I try to fetch data from mysql using jdbc logstash plugin, I'm facing below error
:exception=>#<TypeError: no implicit conversion of Integer into String>
It is happening with a particular table only , working for other tables.
input{
jdbc {
jdbc_driver_library => "/usr/share/jdbc_driver/mysql-connector-java-5.1.47.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
jdbc_connection_string => "jdbc:mysql://:3306/"
jdbc_user => ""
jdbc_password => "<password"
statement => "select * from entitlement_snapshot"
}
}
filter {
mutate {
convert => {
"account_only" => "integer"
}
}
}
output{
elasticsearch {
hosts => ["localhost:9200"]
index => "agco-entitlements-mysql"
document_id => "%{id}"
}
stdout {
codec => rubydebug
}
}