监控指定kafka connector的状态是否正常。

1、监控脚本

import requests
import sys
import time

print("传入的参数列表：", sys.argv[1:])

connector_name = sys.argv[1]

connect_url = "http://192.168.1.211:8083"
resp = requests.get(f"{connect_url}/connectors/{connector_name}/status")
data = resp.json()

while True:
    # 判断connector是否运行
    if data["connector"]["state"] != "RUNNING":
        print("ALERT: Connector not running!")
        sys.exit(1)

    # 判断onnector的各个task是否运行
    for task in data["tasks"]:
        if task["state"] != "RUNNING":
            print(f"ALERT: Task {task['id']} failed!")
            sys.exit(1)

    print(f"connector【{connector_name}】运行正常！")
    
    time.sleep(7200)

2、使用

监控connector：debezium-mysql-connector-finance

python /home/phoenix/git/my_spider/kafka/kafka_connector_check.py "debezium-mysql-connector-finance"