Update read_policy.py

1 files changed, 4 insertions, 4 deletions

diff --git a/read_policy.py b/read_policy.py
index 4e5cb20..fc15c6a 100644
--- a/read_policy.py
+++ b/read_policy.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, policy_table, policy_topic = readIni(0)
-logger = Logger("policy")
+kafHost, cliHost, policy_table, policy_topic, policy_group = readIni(0)
+logger = log_init("policy_log")
 
 try:
     client = clic_client(cliHost)
@@ -10,7 +10,7 @@ except:
     logger.error("clickhouse connect failed")
 
 try:
-    consumer_policy = kafka_consumer(policy_topic, kafHost)
+    consumer_policy = kafka_consumer(policy_topic, policy_group, kafHost)
 except:
     logger.error("kafka connect failed")