input {
jdbc {
schedule => "*****"
statement => "SELECT id, mycolumn1, mycolumn2 FROM my_table WHERE id > :sql_last_value"
use_column_value => true
tracking_column => "id"
# ... other configuration bits
}
}
Above schedule will run the statement, in Cron format for example: "* * * * *" (execute query every minute, on the minute)
1 Like