From 783cde39207b313a7e6e32294e99ffbaf7bd6877 Mon Sep 17 00:00:00 2001 From: Jorge Espinosa Date: Wed, 30 Apr 2025 09:39:58 -0500 Subject: [PATCH] Remove -event from groupid --- .../async/kafka/listeners/ApplicationEventListener.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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; }