canal
canal copied to clipboard
writeOut 组间适配器并行运行 bug?
AdapterProcessor 类的 writeOut 方法,对于组间适配器并行运行的代码逻辑是不是有bug,我的理解是所有任务都 add 到futures 后,再对 futures 遍历 get 结果,如图
这里的注释组间适配器并行运行其实是触发不到的,因为每个组都会实例化一个AdapterProcessor。。。配置多个组并行的其实是AdapterProcessor