Update read_status.py

1 files changed, 4 insertions, 4 deletions

diff --git a/read_status.py b/read_status.py
index d73b44e..3980f32 100644
--- a/read_status.py
+++ b/read_status.py
@@ -1,8 +1,8 @@
 
-from log import save_log, kafka_consumer, clic_client, readIni, Logger
+from log import save_log, kafka_consumer, clic_client, readIni, log_init
 
-kafHost, cliHost, status_table, status_topic = readIni(1)
-logger = Logger("status")
+kafHost, cliHost, status_table, status_topic, status_group = readIni(1)
+logger = log_init("status_log")
 
 try:
     client = clic_client(cliHost)
@@ -10,7 +10,7 @@ except:
     logger.error("clickhouse connect failed")
 
 try:
-    consumer_status = kafka_consumer(status_topic, kafHost)
+    consumer_status = kafka_consumer(status_topic, status_group, kafHost)
 except:
     logger.error("kafka connect failed")