Merge pull request #2 from DiSSCo/bug-fix/add-profile-configuration

Add profile in kafka consumer configuration
DiSSCo · Sep 26, 2022 · 0ea5050 · 0ea5050
2 parents 8da9449 + 1b0a41a
commit 0ea5050
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...ava/eu/dissco/core/digitalspecimenprocessor/configuration/KafkaConsumerConfiguration.java b/...ava/eu/dissco/core/digitalspecimenprocessor/configuration/KafkaConsumerConfiguration.java
@@ -1,5 +1,6 @@
 package eu.dissco.core.digitalspecimenprocessor.configuration;
 
+import eu.dissco.core.digitalspecimenprocessor.Profiles;
 import eu.dissco.core.digitalspecimenprocessor.property.KafkaConsumerProperties;
 import java.util.HashMap;
 import java.util.Map;
@@ -8,12 +9,14 @@
 import org.apache.kafka.common.serialization.StringDeserializer;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Profile;
 import org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory;
 import org.springframework.kafka.core.ConsumerFactory;
 import org.springframework.kafka.core.DefaultKafkaConsumerFactory;
 
 @Configuration
 @AllArgsConstructor
+@Profile(Profiles.KAFKA)
 public class KafkaConsumerConfiguration {
 
   private final KafkaConsumerProperties properties;