no message

Pyspark_job/utils/templates.py

@@ -94,7 +94,7 @@ class Templates(object):
         self.test_flag = 'normal'
         self.beginning_offsets_dict = {}  # history消费时, 初始的偏移量
         # redis连接对象--用来锁定--解决并发
-        self.client = redis.Redis(host='192.168.10.224', port=6379, db=9, password='yswg2023')
+        self.client = redis.Redis(host='192.168.10.224', port=6379, db=9, password='xA9!wL3pZ@q2')
 
     def create_spark_object(self, app_name=None):
         if self.topic_name != '':