diff --git a/async/async-kafka/src/main/java/org/reactivecommons/async/kafka/listeners/ApplicationEventListener.java b/async/async-kafka/src/main/java/org/reactivecommons/async/kafka/listeners/ApplicationEventListener.java
index 50a19375..56b0e745 100644
--- a/async/async-kafka/src/main/java/org/reactivecommons/async/kafka/listeners/ApplicationEventListener.java
+++ b/async/async-kafka/src/main/java/org/reactivecommons/async/kafka/listeners/ApplicationEventListener.java
@@ -34,7 +34,7 @@ public ApplicationEventListener(ReactiveMessageListener receiver,
                                     CustomReporter errorReporter,
                                     String appName) {
         super(receiver, withDLQRetry, createTopology, maxRetries, retryDelay, discardNotifier,
-                "event", errorReporter, appName + "-events", resolver.getEventNames());
+                "event", errorReporter, appName, resolver.getEventNames());
         this.resolver = resolver;
         this.messageConverter = messageConverter;
     }