Debezium 在发出初始 DROP TABLE 事件时中断

Question

我正在尝试使用 MariaDB 和 ActiveMQ 设置 Debezium 引擎。我正在使用 Quarkus 框架。我正在关注官方文档 (https://debezium.io/documentation/reference/development/engine.html)。当我启动引擎时，出现以下错误：

2021-05-03 10:05:53,184 INFO  [io.deb.pip.sou.AbstractSnapshotChangeEventSource] (debezium-mysqlconnector-my-app-connector-change-event-source-coordinator) Snapshot - Final stage
2021-05-03 10:05:53,184 WARN  [io.deb.pip.ChangeEventSourceCoordinator] (debezium-mysqlconnector-my-app-connector-change-event-source-coordinator) Change event source executor was interrupted: java.lang.InterruptedException: Interrupted while emitting initial DROP TABLE events

不太确定为什么会发生这种情况，到目前为止我还无法找到问题的根源，因此我们将不胜感激。

Answer 1

我能够通过删除使用属性 offset.storage.file.filename.

配置的文件来解决此问题

Answer 2

// Run the engine asynchronously ...
ExecutorService executor = Executors.newSingleThreadExecutor();
executor.execute(engine);

// Do something else or wait for a signal or an event

确保做一些等待，否则连接器线程将被主线程终止，您将收到类似“快照在完成前被中断”的消息。

Debezium 在发出初始 DROP TABLE 事件时中断

Debezium Interrupted while emitting initial DROP TABLE events

java

debezium