如何阻止Kafka的任务?

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

我在经营一家公司 sinkTask 使用 connect-standalone.sh 和connect-standalone.properties。我是在一个shell脚本中完成这项工作的,我不知道一旦使用者使用了数据,如何停止sinktask。
我在属性文件中尝试了各种设置,比如 connections.max.idle.ms=5000 . 但什么也阻止不了Flume。
我不想尝试分布式模式,因为它需要restapi调用。一旦生产者中的消息为空,有人建议停止任务吗?

myzjeezk

myzjeezk1#

在独立模式下运行时,停止连接器的唯一方法是停止开始的连接进程 connect-standalone.sh .
如果您想经常启动和停止连接器,我建议您重新考虑分布式模式,因为它可以通过restapi轻松地控制连接器的生命周期。

相关问题