修改

Home/Lib/Action/BatteryAlarmKafkaAction.class.php

@@ -12,13 +12,13 @@ class BatteryAlarmKafkaAction extends Action {
 		if (empty($broker_list)) {
 			exit("KAFKA_BROKER_LIST must be config!".PHP_EOL);
 		}
-		$group = C('WXT_DATA_KAFKA_GROUP');
+		$group = C('T65_DATA_KAFKA_GROUP');
 		if (empty($group)) {
-			exit("WXT_DATA_KAFKA_GROUP must be config!".PHP_EOL);
+			exit("T65_DATA_KAFKA_GROUP must be config!".PHP_EOL);
 		}
-		$topics = C('C61_BATTERY_ALARM_KAFKA_TOPIC');
+		$topics = C('T65_BATTERY_ALARM_KAFKA_TOPIC');
 		if (empty($topics)) {
-			exit("C61_BATTERY_ALARM_KAFKA_TOPIC must be config!".PHP_EOL);
+			exit("T65_BATTERY_ALARM_KAFKA_TOPIC must be config!".PHP_EOL);
 		}
 		$topics = explode(',',$topics);
 		$conf = new RdKafka\Conf();