event

jaychuo · Jul 22, 2022 · d659cae · d659cae
1 parent 1c60512
commit d659cae
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/.../main/java/com/github/linyuzai/event/kafka/autoconfigure/KafkaEventAutoConfiguration.java b/.../main/java/com/github/linyuzai/event/kafka/autoconfigure/KafkaEventAutoConfiguration.java
@@ -11,6 +11,7 @@
 import org.springframework.boot.autoconfigure.AutoConfigureBefore;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
 import org.springframework.boot.autoconfigure.kafka.KafkaAutoConfiguration;
 import org.springframework.boot.context.properties.EnableConfigurationProperties;
 import org.springframework.boot.context.properties.PropertyMapper;
@@ -38,6 +39,7 @@
 
 @Configuration
 @ConditionalOnClass(EnableKafka.class)
+@ConditionalOnProperty(name = "concept.event.kafka.enabled", havingValue = "true", matchIfMissing = true)
 @ConditionalOnBean(name = "com.github.linyuzai.event.autoconfigure.EventEnabled")
 @EnableConfigurationProperties(KafkaEventProperties.class)
 @AutoConfigureBefore(KafkaAutoConfiguration.class)

diff --git a/sample/src/main/resources/application.yml b/sample/src/main/resources/application.yml
@@ -81,7 +81,11 @@ concept:
           inherit: parent
           bootstrap-servers:
             - 192.168.30.140:9092
+          consumer:
+            group-id: sample-local
         dev:
           inherit: parent
           bootstrap-servers:
-            - 192.168.30.140:9092
+            - 192.168.30.140:9092
+          consumer:
+            group-id: sample-dev