Explorar o código

kafka条数拉取配置新增

易涛 %!s(int64=3) %!d(string=hai) anos
pai
achega
1e12c5b610
Modificáronse 1 ficheiros con 4 adicións e 3 borrados
  1. 4 3
      src/main/resources/application.yml

+ 4 - 3
src/main/resources/application.yml

@@ -45,13 +45,13 @@ spring:
       ddl-auto: none
   kafka:
     enable: false
-    bootstrapServers: 100.76.25.12:4439,100.76.25.13:4439,100.76.25.14:4439
+    bootstrapServers: 113.108.52.72:4439,113.108.52.72:4440
     ssl:
       #protocol: SSL
       key-password: cmsk-ioc-1234 #kafkadockerclient
-      key-store-location: file:config/client.keystore.jks # file://e:\certs\docker.kafka.client.keystore.jks
+      key-store-location: file://D:\client.keystore.jks # file://e:\certs\docker.kafka.client.keystore.jks
       key-store-password: cmsk-ioc-1234 #kafkadockerclient
-      trust-store-location: file:config/client.truststore.jks #file://e:\certs\docker.kafka.client.truststore.jks
+      trust-store-location: file://D:\client.truststore.jks #file://e:\certs\docker.kafka.client.truststore.jks
       trust-store-password: cmsk-ioc-1234 #kafkadockerclient
     producer:
       # 发生错误后,消息重发的次数。
@@ -84,6 +84,7 @@ spring:
       properties:
         security.protocol: SSL
         ssl.endpoint.identification.algorithm:
+      max-poll-records: 5000
     listener:
       # 在侦听器容器中运行的线程数。
       concurrency: 5