Added mising @DefaultBean annotation to KafkaConsumerFactory.

dartartem · Jan 15, 2021 · e03c131 · e03c131
1 parent 195f581
commit e03c131
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...java/io/eventuate/messaging/kafka/quarkus/consumer/KafkaConsumerFactoryConfiguration.java b/...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();
   }