专题审核增加评价中心审核逻辑

src/main/java/com/zzsn/event/service/impl/InformationServiceImpl.java

@@ -805,7 +805,7 @@ public class InformationServiceImpl implements InformationService {
                 //评价中心审核逻辑
                 if (subjectdatabase.getSubjectId().equals("1933103248232779778")) {
                     subjectdatabase.setDbIndex(index);
-                    kafkaTemplate.send("gzjg_data_info", JSONUtil.toJsonStr(subjectdatabase));
+                    kafkaTemplate.send("gzjg_information", JSONUtil.toJsonStr(subjectdatabase));
                 }
             });
         }

src/main/resources/application-dev.yml

@@ -95,14 +95,6 @@ spring:
       # 指定消息key和消息体的编解码方式
       key-serializer: org.apache.kafka.common.serialization.StringSerializer
       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-dev
@@ -117,13 +109,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";
+    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:

src/main/resources/application-test.yml

@@ -97,14 +97,6 @@ spring:
       # 指定消息key和消息体的编解码方式
       key-serializer: org.apache.kafka.common.serialization.StringSerializer
       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-test
@@ -119,13 +111,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";
+    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: