如何使用 java 捕获嵌入式 debezium 数据库连接失败?
How to capture Embedded-debezium database connection failures with java?
在我基于嵌入式 debezium 的 CDC 应用程序中,我想捕获数据库连接失败以自动重试连接。
有没有办法捕捉到我的程序中数据库连接失败?
使用 CompletionCallback
.
构建 EmbeddedEngine
EmbeddedEngine.CompletionCallback completionCallback = (success, message, error) -> {
//Handle the error.
};
EmbeddedEngine engine = EmbeddedEngine.create()
.using(completionCallback)
...
.build();
在我基于嵌入式 debezium 的 CDC 应用程序中,我想捕获数据库连接失败以自动重试连接。
有没有办法捕捉到我的程序中数据库连接失败?
使用 CompletionCallback
.
EmbeddedEngine
EmbeddedEngine.CompletionCallback completionCallback = (success, message, error) -> {
//Handle the error.
};
EmbeddedEngine engine = EmbeddedEngine.create()
.using(completionCallback)
...
.build();