如何在Kafka源连接器YAML中定时重启JDBC连接器？

不行，Kafka JDBC源连接器的YAML配置里没有内置支持定时自动重启的参数，没法直接在连接器配置里实现定时重启逻辑。

不过你可以通过以下两种方式实现类似效果：

1. 结合REST API和定时任务工具 #

Kafka Connect提供了REST API来管理连接器，你可以写个简单脚本调用重启接口，再用定时任务工具（比如Linux的cron、Windows任务计划）定期执行：

• 重启连接器的curl命令示例：

  curl -X POST http://<你的Connect集群地址>:<端口>/connectors/<你的连接器名称>/restart
  

• 如果是Linux系统，你可以把命令存成脚本，然后在crontab里配置定时规则，比如每天凌晨2点重启：

  0 2 * * * /usr/bin/bash /path/to/restart-oracle-connector.sh
  

2. 配置失败自动重启（仅针对报错场景） #

如果你的连接器是因为报错停止的，可以在Kafka Connect Worker的配置里开启自动重启机制：

• 在worker的worker.properties里添加：

  restart.on.failure=true
  restart.backoff.ms=5000  # 重启前等待5秒
  max.restart.attempts=3    # 最多重试3次
  

• 同时在连接器YAML里配置错误容忍和重试参数：

  errors.tolerance: all
  errors.retry.timeout.ms: 300000
  errors.retry.delay.max.ms: 60000
  

  但注意这个方案只针对任务报错的情况，对于无报错但停止接收数据的场景不生效。

更建议的：排查根本问题 #

定时重启只是临时 workaround，建议你先定位问题根源：

• 检查Kafka Connect的日志（特别是连接器的输出日志），哪怕任务没报错，也可能有警告信息（比如连接池耗尽、数据库会话超时）
• 验证Oracle JDBC驱动版本和Kafka Connect版本的兼容性
• 在连接器的connection.url里添加连接存活检测参数，比如：

  jdbc:oracle:thin:@//<db-host>:<port>/<service-name>?oracle.net.CONNECT_TIMEOUT=10000&oracle.net.READ_TIMEOUT=30000&validationQuery=SELECT 1 FROM DUAL&testOnBorrow=true
  

• 检查Oracle数据库侧的状态：是否有锁表、归档日志已满、CDC日志读取卡住（如果用的是CDC模式）

内容的提问来源于stack exchange，提问作者OdiumPura