kafka配置修改

src/main/resources/application-dev.yml

@@ -49,14 +49,14 @@ spring:
         connectionProperties: druid.stat.mergeSql\=true;druid.stat.slowSqlMillis\=5000
       datasource:
         master:
-          url: jdbc:mysql://1.95.14.228:3306/clb_project?useUnicode=true&characterEncoding=utf-8&AllowPublicKeyRetrieval=True&serverTimezone=Asia/Shanghai&autoReconnect=true&rewriteBatchedStatements=true
+          url: jdbc:mysql://1.95.78.131:3306/clb_project_label?useUnicode=true&characterEncoding=utf-8&AllowPublicKeyRetrieval=True&serverTimezone=Asia/Shanghai&autoReconnect=true&rewriteBatchedStatements=true
           username: ciglobal
-          password: _PSuWVQ4CLpX
+          password: qwer@9988&zzsn
           driver-class-name: com.mysql.cj.jdbc.Driver
         multi-datasource1:
-          url: jdbc:mysql://1.95.14.228:3306/clb_xxl_job?characterEncoding=UTF-8&useUnicode=true&useSSL=false&tinyInt1isBit=false&allowPublicKeyRetrieval=true&serverTimezone=Asia/Shanghai
+          url: jdbc:mysql://1.95.78.131:3306/clb_xxl_job_label?characterEncoding=UTF-8&useUnicode=true&useSSL=false&tinyInt1isBit=false&allowPublicKeyRetrieval=true&serverTimezone=Asia/Shanghai
           username: ciglobal
-          password: _PSuWVQ4CLpX
+          password: qwer@9988&zzsn
           driver-class-name: com.mysql.cj.jdbc.Driver
   elasticsearch:
     uris: ["1.95.38.69:9700","1.95.3.121:9200","1.95.87.177:9700"]
@@ -73,7 +73,7 @@ spring:
           requiredAcks: 1
   redis:
     database: 7
-    host: 1.95.69.2
+    host: 127.0.0.1
     lettuce:
       pool:
         max-active: 8   #最大连接数据库连接数,设 0 为没有限制
@@ -81,10 +81,10 @@ spring:
         max-wait: -1ms  #最大建立连接等待时间。如果超过此时间将接到异常。设为-1表示无限制。
         min-idle: 0     #最小等待连接中的数量,设 0 为没有限制
       shutdown-timeout: 100ms
-    port: 6380
-    password: RPHZgkDQ4zGJ
+    port: 6379
+    password: clbzzsn
   kafka:
-    bootstrap-servers: 1.95.78.131:9092
+    bootstrap-servers: 1.95.78.131:17092
     producer: # 生产者
       retries: 3 # 设置大于0的值，则客户端会将发送失败的记录重新发送
       batch-size: 16384

src/main/resources/application-pro.yml

@@ -81,7 +81,7 @@ spring:
     port: 6380
     password: RPHZgkDQ4zGJ
   kafka:
-    bootstrap-servers: 1.95.78.131:9092
+    bootstrap-servers: 192.168.0.180:7092
     producer: # 生产者
       retries: 3 # 设置大于0的值，则客户端会将发送失败的记录重新发送
       batch-size: 16384
@@ -93,6 +93,12 @@ spring:
       value-serializer: org.apache.kafka.common.serialization.StringSerializer
       properties:
         max.request.size: 335544324 #32M
+        security:
+          protocol: SASL_PLAINTEXT
+          sasl:
+            mechanism: PLAIN
+            jaas:
+              config: org.apache.kafka.common.security.plain.PlainLoginModule required username="admin" password="admin-zzsn9988";
     consumer:
       #用于标识此使用者所属的使用者组的唯一字符串
       group-id: event-analysis-group
@@ -107,6 +113,13 @@ spring:
       key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
       #值的反序列化器类，实现类实现了接口org.apache.kafka.common.serialization.Deserializer
       value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
+      properties:
+        security:
+          protocol: SASL_PLAINTEXT
+        sasl:
+          mechanism: PLAIN
+          jaas:
+            config: org.apache.kafka.common.security.plain.PlainLoginModule required username="admin" password="admin-zzsn9988";
   main:
     allow-circular-references: true
 mybatis-plus: