Add param variable for group id

Author: jespinosas

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, resolver.getEventNames());
+
         this.resolver = resolver;
         this.messageConverter = messageConverter;
     }

starters/async-commons-starter/src/main/java/org/reactivecommons/async/starter/props/GenericAsyncProps.java

@@ -13,6 +13,7 @@
 @SuperBuilder
 public abstract class GenericAsyncProps<P> {
     private String appName;
+    private String groupId;
     private String secret;
 
     public abstract void setConnectionProperties(P properties);

starters/async-commons-starter/src/main/java/org/reactivecommons/async/starter/props/GenericAsyncPropsDomain.java

@@ -22,6 +22,7 @@ public class GenericAsyncPropsDomain<T extends GenericAsyncProps<P>, P> extends
     private Class<P> propsClass;
 
     public GenericAsyncPropsDomain(String defaultAppName,
+                                   String groupId,
                                    P defaultProperties,
                                    GenericAsyncPropsDomainProperties<T, P> configured,
                                    SecretFiller<P> secretFiller,
@@ -44,7 +45,10 @@ 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);
+                }
+                value.setAppName(defaultAppName + "-events");
             }
             if (value.getConnectionProperties() == null) {
                 if (defaultProperties == null) {

starters/async-kafka-starter/src/main/java/org/reactivecommons/async/kafka/config/props/AsyncKafkaPropsDomain.java

@@ -13,10 +13,11 @@
 public class AsyncKafkaPropsDomain extends GenericAsyncPropsDomain<AsyncKafkaProps, KafkaProperties> {
 
     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);
     }