监控指定kafka connector的状态是否正常。 1、监控脚本 import requests import sys import time print("传入的参数列表：", sys.argv[1:]) connector_name = sys.argv[1] connect_url