如何使用新配置重新启动失败的任务

qnzebej0  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(410)

每当我们重新启动一个失败的任务时,它总是会选择失败时的配置,并以此运行。。然后它会选择新的配置。。同时也在运行。
我们有暂停、更新配置然后继续的连接作业。除非任务失败,否则这项工作正常。
如果我们重新启动失败的任务,即使连接器有更新的配置,任务也会以旧配置启动。。运行到完成/失败。。然后将使用新配置启动一个新任务。
这会导致各种数据/etc问题。。如果你真的不想用这个配置运行旧任务。
有没有办法用失败的任务重新启动连接器。。使用新配置。。不调用旧配置?
(运行Kafkav2.5,顺便说一句)

c9x0cxw0

c9x0cxw01#

我不知道任务获取最新配置是否合理。例如,假设连接器启动10个不同的任务,其中一个失败。当失败的任务重新启动后运行最新的配置时,让连接器的其余9个任务使用较旧的配置运行是没有意义的。
我想说的是,如果您希望在任务失败时使用新的/不同的配置文件,那么重新启动连接器而不是单个任务可能更有意义:

POST /connectors/connector-name/restart HTTP/1.1

相关问题