postgresql - 使用 postgresql 字段类型文本过滤 kafka 消息时出错

Question

错误 || WorkerSourceTask{id=ptl_connector-0} 任务引发了一个未捕获且不可恢复的异常 [org.apache.kafka.connect.runtime.WorkerTask] org.apache.kafka.connect.errors.ConnectException：在 org.apache 的错误处理程序中超出了容差。 kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.java:178) 在 org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execute(RetryWithToleranceOperator.java:104) 在 org.apache.kafka.connect。 runtime.TransformationChain.apply(TransformationChain.java:50) 在 org.apache.kafka.connect.runtime.WorkerSourceTask.sendRecords(WorkerSourceTask.java:320) 在 org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask. java:245) 在 org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:184) 在 org.apache.kafka.connect.runtime。

标签： postgresqlapache-kafkadebezium

Answer 1

您是否考虑过使用kafka连接器来做到这一点？也许这会有所帮助： https ://docs.confluent.io/current/connect/transforms/filter.html