can pass port to consumer and run two consumers at once

Author: jphaugla

runconsumer2.sh

@@ -0,0 +1 @@
+mvn exec:java -Dexec.mainClass="com.jphaugla.redis.streams.RedisStreams101Consumer" -Dexec.args="12002"

src/main/java/com/jphaugla/redis/streams/RedisStreams101Consumer.java

@@ -23,7 +23,7 @@ public static void main(String[] args) {
         RedisCommands<String, String> syncCommands = connection.sync();
 
         try {
-            syncCommands.xgroupCreate( XReadArgs.StreamOffset.from(STREAMS_KEY, "0-0"), "application_1"  );
+            syncCommands.xgroupCreate( XReadArgs.StreamOffset.from(STREAMS_KEY, "0-0"), "application_1", XGroupCreateArgs.Builder.mkstream() );
         }
         catch (RedisBusyException redisBusyException) {
             System.out.printf("\t Group '%s' already exists%n", "application_1");