canal客户端使用多线程消费消息
由于canal消费时是单线程阻塞的，大大降低了程序对于线程的利用率canal客户端实现官方demo //保存被消费的消息记录和状态 private static List<CanalTaskStatus> listTaskStatus = Collections.synchronizedList(new ArrayList<>()); //正在被消费的batchId private static Set<Lo
