Update alarm_kafka_connect.py

dags/kafka/alarm_kafka_connect.py

@@ -172,7 +172,7 @@ def python_callable(**kwargs):
             error_msg += msg
     if error_msg:
         raise Exception(error_msg)
-    logger.error('kafka connect status ok!')
+    logger.info('kafka connect status ok!')
 
 for service in SERVICES:
     task = PythonOperator(