kafka添加开关

diff --git a/config/application-devel-pg.properties b/config/application-devel-pg.properties
index 6b289c2..26e1499 100644 (file)
--- 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 96a01e1..a5cc0e8 100644 (file)
--- 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()){