confluent-schema-registry - 如何忽略 kafka jdbc sink 连接器中的错误消息？

Question

我正在使用 kafka JDBC 连接器将数据从 kafka 主题推送到 aws 上的 postgres。但是，当出现错误消息时，例如，消息中的数据类型与数据库中定义的不同，我会收到错误消息：

错误 WorkerSinkTask{id=postgres_sink -0} 任务引发了未捕获且不可恢复的异常。任务被杀死，直到手动重新启动才能恢复。(org.apache.kafka.connect.runtime.WorkerSinkTask:584)

然后我必须手动删除我的 jdbc sink 连接器（pod）并让它启动一个新的。由于我在独立模式下运行，我需要防止连接器（pod）失败或因为插入失败而自动重启。

标签： confluent-schema-registry