kafka配置

config-init/config/bean-kafka-config.yaml

@@ -3,7 +3,7 @@ spring:
     bootstrap-servers: b-3.rgccrkafkauat.v3smv9.c2.kafka.cn-northwest-1.amazonaws.com.cn:9096,b-1.rgccrkafkauat.v3smv9.c2.kafka.cn-northwest-1.amazonaws.com.cn:9096,b-2.rgccrkafkauat.v3smv9.c2.kafka.cn-northwest-1.amazonaws.com.cn:9096
     bootstrap-servers: b-3.rgccrkafkauat.v3smv9.c2.kafka.cn-northwest-1.amazonaws.com.cn:9096,b-1.rgccrkafkauat.v3smv9.c2.kafka.cn-northwest-1.amazonaws.com.cn:9096,b-2.rgccrkafkauat.v3smv9.c2.kafka.cn-northwest-1.amazonaws.com.cn:9096
     consumer:
     consumer:
       #默认消费者组
       #默认消费者组
-      #group-id: test-consumer-group
+      group-id: my-consumer-group
       #最早未被消费的offset
       #最早未被消费的offset
       auto-offset-reset: latest
       auto-offset-reset: latest
       #是否自动提交
       #是否自动提交
@@ -11,7 +11,10 @@ spring:
     properties:
     properties:
       security:
       security:
         protocol: SASL_SSL
         protocol: SASL_SSL
+      ssl:
+        truststore:
+          location: D:\data\kafka.client.truststore.jks
       sasl:
       sasl:
         mechanism: SCRAM-SHA-512
         mechanism: SCRAM-SHA-512
         jaas:
         jaas:
-            config: org.apache.kafka.common.security.scram.ScramLoginModule required username="rgccr-rice-bean-uat" password="czJavntCRSeLc";
+          config: 'org.apache.kafka.common.security.scram.ScramLoginModule required username="rgccr-rice-bean-uat" password="czJavntCRSeLc";'
\ No newline at end of file