首页 > 解决方案 > 防止 Kafka 连接器运行任务重新分配

问题描述

在我的工作中,我们有一个定制的 kafka 连接器。连接器设计为有状态的。

并且有几十个连接器可以在一段时间内启动和停止。因此,当连接器停止时,在工作人员 A 中运行的任务有可能被重新分配给工作人员 B。这可能会导致意外行为。

所以这是我的问题:有没有办法避免正在运行的任务被重新分配给另一个工人?

非常感谢。

标签: apache-kafka-connect

解决方案


推荐阅读