连接器中的任务何时转为未分配状态?

Ren*_*hya 6 apache-kafka apache-kafka-connect

我正在分布式模式下运行 CP3.2,甚至使用“tasks.max”定义的一些连接器:“1”也具有任务“UNASSIGNED”状态。我增加了分配给工作人员的内存并重新启动工作人员解决了我的问题,或者添加一个工作人员解决了这个问题。

如果“tasks.max”> 1 有一些任务处于“未分配”状态,这对我来说没问题,但如果我只定义一个任务,它应该处于“运行”状态。

但我需要了解任务在什么情况下会进入“未分配”状态以及如何解决此问题(使其运行)。

问候,

阿拉迪亚

Kon*_*sis 3

如果已分配运行此连接器任务的工作线程任务成功关闭,则任务将进入UNASSIGNED状态。这与此连接器应该生成的任务总数(tasks.max属性)无关。onShutdown您可以通过跟踪中的方法调用来在代码中跟踪这一点AbstractHerder。转换到UNASSIGNED状态要求正在运行的工作任务未发生任何故障或抛出异常,并且已触发正常关闭。

您的连接器任务是否有可能在其常规迭代循环一开始就停止?你能提供更多信息吗?它是源还是汇?