即使查询失败，Kafka Connect JDBC 源也会运行答案

【问题标题】：Kafka Connect JDBC Source running even when query fails即使查询失败，Kafka Connect JDBC 源也会运行
【发布时间】：2021-09-06 15:37:25
【问题描述】：

我正在运行 JDBC 源连接器，并尝试通过公开的 JMX 指标和 prometheus 导出器以某种方式监控其状态。但是，当查询失败或无法访问 db 时，连接器及其所有任务的状态仍处于运行状态。

在早期版本中，在我使用的版本（connect-runtime-6.2.0-ccs、confluentinc-kafka-connect -jdbc-10.2.0, jmx_prometheus_javaagent-0.14.0)，即使指标失败，也会以 0.0 值导出。

有什么方法可以检测到这样一个失败的查询或数据库连接吗？

【问题讨论】：

【解决方案1】：

这已在 jdbc 连接器的 10.2.4 版本中得到解决。现在，当出现 SQLNonTransientException 时，任务会失败，这可以使用导出的指标来检测。见https://github.com/confluentinc/kafka-connect-jdbc/pull/1096

【讨论】：