clientid

trans2es/management/commands/trans2es_data2es_redis.py

@@ -30,7 +30,7 @@ class Command(BaseCommand):
     def handle(self, *args, **options):
         try:
             if len(options["sync_type"]) and options["sync_type"] == "auto_vest":
-                kafka_consum(clientid)
+                kafka_consum()
                 logging.info("add a log >>>>>  auto_vest")
 
         except: