From: qiaowei <jov123@163.com>
Date: Mon, 14 Oct 2019 08:37:42 +0000 (+0800)
Subject: kafka添加开关
X-Git-Url: https://source.supwisdom.com/gerrit/gitweb?a=commitdiff_plain;h=d9dcd4710db48126261256480f36b0e396575d87;p=epayment%2Ffood_payapi.git

kafka添加开关
---

diff --git a/config/application-devel-pg.properties b/config/application-devel-pg.properties
index 6b289c2b..26e14990 100644
--- a/config/application-devel-pg.properties
+++ b/config/application-devel-pg.properties
@@ -47,6 +47,7 @@ spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.Str
 
 #===============kafka consumer  =======================
 # 指定默认消费者group id
+spring.kafka.listen.auto.start=false
 spring.kafka.consumer.group-id=epaymessager1
 spring.kafka.consumer.auto-offset-reset=earliest
 spring.kafka.consumer.enable-auto-commit=true
diff --git a/payapi/src/main/kotlin/com/supwisdom/dlpay/api/service/kafka_service.kt b/payapi/src/main/kotlin/com/supwisdom/dlpay/api/service/kafka_service.kt
index 96a01e1f..a5cc0e8c 100644
--- a/payapi/src/main/kotlin/com/supwisdom/dlpay/api/service/kafka_service.kt
+++ b/payapi/src/main/kotlin/com/supwisdom/dlpay/api/service/kafka_service.kt
@@ -16,7 +16,7 @@ class  KafkaMsgListener{
     @Autowired
     private lateinit var msgDao: MsgDao
 
-    @KafkaListener(topics = ["jpush-messages-result"])
+    @KafkaListener(topics = ["jpush-messages-result"],autoStartup = "\${spring.kafka.listen.auto.start:true}")
     fun listen(record :ConsumerRecord<String, String>) {
         logger.debug { "${record.key()},${record.value()}" }
         if(!record.key().isNullOrEmpty()){