有什么方法可以在Apache Camel中自动重新启动Debezium连接器？

Question

我正在使用 debezium sql sql sql sql serve camel camel for apache camel 从一个数据库更改为另一个数据库。

@Configuration
class DebeziumRoute extends RouteBuilder {
    @Override
    public void configure() {
        from("debezium-sqlserver:iwdcamel" +
                "?databaseServerName=iwdcamel" +
                "&databaseHostname=localhost" +
                "&databasePort=1433" +
                "&databaseDbname=MyDB" +
                "&databaseUser=sa" +
                "&databasePassword=MyPassword" +
                "&tableWhitelist=dbo.MyTable" +
                "&offsetStorageFileName=./offset-file.dat" +
                "&databaseHistoryFileFilename=./history-file.dat")
            .choice()
                ...
            .end();
    }
}

一切正常，除了出于某种原因数据库或网络下降时，连接器停止并且即使数据库在几秒钟内恢复也不会重新启动。

io.debezium.embedded.EmbeddedEngine: Error while trying to run connector class 'io.debezium.connector.sqlserver.SqlServerConnector'

org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.

com.microsoft.sqlserver.jdbc.SQLServerException: SQL Server no devolvió una respuesta. Se ha cerrado la conexión.

有什么方法可以自动重新启动 debezium 连接器？，至少...

有什么方法可以定期检查连接器的状态并在需要时重新启动？

欢迎任何想法...