如何解决这个问题?
org.apache.kafka.connect.errors.connectexception:此工作进程中已存在任务
我们已经在单个服务器上设置了kafka和kafka connect,我的所有连接器都给出了上述错误。
另外,在重新启动connect服务之后,所有worker都被困在unassigned模式中。
如何解决这个问题?
org.apache.kafka.connect.errors.connectexception:此工作进程中已存在任务
我们已经在单个服务器上设置了kafka和kafka connect,我的所有连接器都给出了上述错误。
另外,在重新启动connect服务之后,所有worker都被困在unassigned模式中。
1条答案
按热度按时间kx1ctssn1#
我自己也遇到了这个错误,并设法通过ssh连接到报告错误的connect服务器来修复它,停止所有正在运行的kafka connect示例。
sudo systemctl stop kafka-connect
,或SIGTERM
它然后通过
systemctl start kafka-connect
,或connect-distributed
或者,您也可以尝试httpDELETE
&回复-POST
连接器配置。