From 94eecad156b40fbe1a14d9f8b7fe17cab2b5454c Mon Sep 17 00:00:00 2001
From: qiaowei <jov123@163.com>
Date: Mon, 14 Oct 2019 16:37:42 +0800
Subject: [PATCH] =?utf8?q?kafka=E6=B7=BB=E5=8A=A0=E5=BC=80=E5=85=B3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit

---
 config/application-devel-pg.properties                          | 1 +
 .../kotlin/com/supwisdom/dlpay/api/service/kafka_service.kt     | 2 +-
 2 files changed, 2 insertions(+), 1 deletion(-)

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()){
-- 
2.17.1