Как перехватить ошибки подключения к базе данных Embedded-debezium с помощью Java?

Question

Во встроенном CDC-приложении на основе debezium я хочу перехватить соединения с базой данных, чтобы автоматически повторить попытку соединения.

Есть ли способ отловить, что соединение с базой данных не удалось в моей программе?

Answer 1

Сборка EmbeddedEngine с использованием CompletionCallback.

EmbeddedEngine.CompletionCallback completionCallback = (success, message, error) -> {
    //Handle the error.
};
EmbeddedEngine engine = EmbeddedEngine.create()
                        .using(completionCallback)
                        ...
                        .build();