kafka添加开关
diff --git a/config/application-devel-pg.properties b/config/application-devel-pg.properties
index 6b289c2..26e1499 100644
--- a/config/application-devel-pg.properties
+++ b/config/application-devel-pg.properties
@@ -47,6 +47,7 @@
#===============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
--- 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 @@
@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()){