Kafka Connect JDBC Source 运行 即使查询失败

Kafka Connect JDBC Source running even when query fails

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

在早期版本中,在我使用的版本中(connect-runtime-6.2.0-ccs,confluentinc),当查询失败时,似乎没有导出 source-task-metrics 中 source-record-poll-total 的值-kafka-connect-jdbc-10.2.0, jmx_prometheus_javaagent-0.14.0) 即使在失败时,指标也会以值 0.0.

导出

知道如何检测此类失败的查询或数据库连接吗?

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