diff --git a/eventuate-messaging-kafka-quarkus-consumer/src/main/java/io/eventuate/messaging/kafka/quarkus/consumer/KafkaConsumerFactoryConfiguration.java b/eventuate-messaging-kafka-quarkus-consumer/src/main/java/io/eventuate/messaging/kafka/quarkus/consumer/KafkaConsumerFactoryConfiguration.java
index 274b100..1ba42f5 100755
--- a/eventuate-messaging-kafka-quarkus-consumer/src/main/java/io/eventuate/messaging/kafka/quarkus/consumer/KafkaConsumerFactoryConfiguration.java
+++ b/eventuate-messaging-kafka-quarkus-consumer/src/main/java/io/eventuate/messaging/kafka/quarkus/consumer/KafkaConsumerFactoryConfiguration.java
@@ -4,10 +4,12 @@
 import javax.enterprise.inject.Produces;
 import io.eventuate.messaging.kafka.basic.consumer.DefaultKafkaConsumerFactory;
 import io.eventuate.messaging.kafka.basic.consumer.KafkaConsumerFactory;
+import io.quarkus.arc.DefaultBean;
 
 @ApplicationScoped
 public class KafkaConsumerFactoryConfiguration {
   @Produces
+  @DefaultBean
   public KafkaConsumerFactory kafkaConsumerFactory() {
     return new DefaultKafkaConsumerFactory();
   }