diff --git a/src/main/java/eu/dissco/core/digitalspecimenprocessor/configuration/KafkaConsumerConfiguration.java b/src/main/java/eu/dissco/core/digitalspecimenprocessor/configuration/KafkaConsumerConfiguration.java
index 5762268..629b8e1 100644
--- a/src/main/java/eu/dissco/core/digitalspecimenprocessor/configuration/KafkaConsumerConfiguration.java
+++ b/src/main/java/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;