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..ccd6c81e 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 @@ -33,8 +33,11 @@ public ApplicationEventListener(ReactiveMessageListener receiver, DiscardNotifier discardNotifier, 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; } diff --git a/starters/async-commons-starter/src/main/java/org/reactivecommons/async/starter/props/GenericAsyncProps.java b/starters/async-commons-starter/src/main/java/org/reactivecommons/async/starter/props/GenericAsyncProps.java index 20dabcb1..6688fb46 100644 --- a/starters/async-commons-starter/src/main/java/org/reactivecommons/async/starter/props/GenericAsyncProps.java +++ b/starters/async-commons-starter/src/main/java/org/reactivecommons/async/starter/props/GenericAsyncProps.java @@ -13,6 +13,7 @@ @SuperBuilder public abstract class GenericAsyncProps

{ private String appName; + private String groupId; private String secret; public abstract void setConnectionProperties(P properties); diff --git a/starters/async-commons-starter/src/main/java/org/reactivecommons/async/starter/props/GenericAsyncPropsDomain.java b/starters/async-commons-starter/src/main/java/org/reactivecommons/async/starter/props/GenericAsyncPropsDomain.java index a6717026..eb845370 100644 --- a/starters/async-commons-starter/src/main/java/org/reactivecommons/async/starter/props/GenericAsyncPropsDomain.java +++ b/starters/async-commons-starter/src/main/java/org/reactivecommons/async/starter/props/GenericAsyncPropsDomain.java @@ -22,6 +22,7 @@ public class GenericAsyncPropsDomain, P> extends private Class

propsClass; public GenericAsyncPropsDomain(String defaultAppName, + String groupId, P defaultProperties, GenericAsyncPropsDomainProperties configured, SecretFiller

secretFiller, @@ -44,7 +45,13 @@ public GenericAsyncPropsDomain(String defaultAppName, + " has not set the property appName. please use respective property or " + " spring.application.name property or withDefaultAppName in builder"); } - value.setAppName(defaultAppName); + if(value.getGroupId() != null){ + value.setAppName(groupId); + } + else { + value.setAppName(defaultAppName + "-events"); + } + } if (value.getConnectionProperties() == null) { if (defaultProperties == null) { diff --git a/starters/async-kafka-starter/src/main/java/org/reactivecommons/async/kafka/config/props/AsyncKafkaPropsDomain.java b/starters/async-kafka-starter/src/main/java/org/reactivecommons/async/kafka/config/props/AsyncKafkaPropsDomain.java index ea9f9496..f722f7a6 100644 --- a/starters/async-kafka-starter/src/main/java/org/reactivecommons/async/kafka/config/props/AsyncKafkaPropsDomain.java +++ b/starters/async-kafka-starter/src/main/java/org/reactivecommons/async/kafka/config/props/AsyncKafkaPropsDomain.java @@ -13,10 +13,11 @@ public class AsyncKafkaPropsDomain extends GenericAsyncPropsDomain { public AsyncKafkaPropsDomain(@Value("${spring.application.name}") String defaultAppName, + @Value("${spring.kafka.consumer.group.id}") String groupId, KafkaProperties defaultKafkaProperties, AsyncKafkaPropsDomainProperties configured, KafkaSecretFiller kafkaSecretFiller) { - super(defaultAppName, defaultKafkaProperties, configured, kafkaSecretFiller, AsyncKafkaProps.class, + super(defaultAppName, groupId, defaultKafkaProperties, configured, kafkaSecretFiller, AsyncKafkaProps.class, KafkaProperties.class); }