数据库重启导致 CDC 中间件无法继续接收CDC 消息该如何处理？

Question

公司项目用到了 Debezium，遇到一个问题：Debezium 提供了一个 EmbeddedEngine，这个 Engine 的工作流程可以大致简单描述未

run (){

  step1:Engine 内部会 启动一个线程 A，连接 mysql 数据库 读取 binlog 日志，
  并将读取到的数据放置到某一个队列中。
  
  step2:
  while(xxxx){
       //队列中读取数据
       data=queue.take();
       //交给项目的业务类处理
       listeners.forEach(data)
  }
  
}//end run 

问题：我们业务只定义了一个listener 接收处理从队列中读取到的数据。
重启了 mysql 服务器之后，线程 A 抛出了异常导致 无法继续从 mysql 服务器读取 binlog 日志。 然后这个时候 Engine 感知不到 线程A已经死掉了 ，就会一直阻塞在 take 处，我们业务listener也一直收不到data。这个问题有好的处理方式吗？
上面run方法的内部逻辑是我们使用了开源Debezium框架其内部封装好的.