Open simpleusr opened 1 year ago
JDBC API provides java.sql.Statement.setQueryTimeout(int) method to limit query execution time. Currently there is no way to provide such a query timeout for source tasks.
java.sql.Statement.setQueryTimeout(int)
Submitted a pr for this
https://github.com/confluentinc/kafka-connect-jdbc/pull/1270
Regards
JDBC API provides
java.sql.Statement.setQueryTimeout(int)
method to limit query execution time. Currently there is no way to provide such a query timeout for source tasks.