Update alarm_kafka_connect.py

dags/kafka/alarm_kafka_connect.py

@@ -77,7 +77,7 @@ def failure_callback(context):
 def get_kafka_connectors(cmd):
     logging.info('exec cmd:' + cmd)
     connectors_list = []
-    timeout = 10
+    timeout = 30
 
     try:
         result = run_command(cmd, timeout)
@@ -100,7 +100,7 @@ def get_kafka_connectors(cmd):
 
 def get_connector_status(cmd):
     logging.info('exec cmd: ' + cmd)
-    timeout = 10
+    timeout = 30
     outdict = {}
 
     try: