diff --git a/redisson/src/main/java/org/redisson/RedissonStream.java b/redisson/src/main/java/org/redisson/RedissonStream.java
index d2fb10204..87681eeb8 100644
--- a/redisson/src/main/java/org/redisson/RedissonStream.java
+++ b/redisson/src/main/java/org/redisson/RedissonStream.java
@@ -972,6 +972,16 @@ public class RedissonStream<K, V> extends RedissonExpirable implements RStream<K
         get(removeGroupAsync(groupName));
     }
 
+    @Override
+    public void createConsumer(String groupName, String consumerName) {
+        get(createConsumerAsync(groupName, consumerName));
+    }
+
+    @Override
+    public RFuture<Void> createConsumerAsync(String groupName, String consumerName) {
+        return commandExecutor.writeAsync(getName(), StringCodec.INSTANCE, RedisCommands.XGROUP, "CREATECONSUMER", getName(), groupName, consumerName);
+    }
+
     @Override
     public RFuture<Long> removeConsumerAsync(String groupName, String consumerName) {
         return commandExecutor.writeAsync(getName(), StringCodec.INSTANCE, RedisCommands.XGROUP_LONG, "DELCONSUMER", getName(), groupName, consumerName);
diff --git a/redisson/src/main/java/org/redisson/api/RStream.java b/redisson/src/main/java/org/redisson/api/RStream.java
index 77bfd3143..afe9dfff6 100644
--- a/redisson/src/main/java/org/redisson/api/RStream.java
+++ b/redisson/src/main/java/org/redisson/api/RStream.java
@@ -58,6 +58,16 @@ public interface RStream<K, V> extends RStreamAsync<K, V>, RExpirable {
      */
     void removeGroup(String groupName);
 
+    /**
+     * Creates consumer of the group by name.
+     * <p>
+     * Requires <b>Redis 6.2.0 and higher.</b>
+     *
+     * @param groupName - name of group
+     * @param consumerName - name of consumer
+     */
+    void createConsumer(String groupName, String consumerName);
+
     /**
      * Removes consumer of the group by name.
      * 
diff --git a/redisson/src/main/java/org/redisson/api/RStreamAsync.java b/redisson/src/main/java/org/redisson/api/RStreamAsync.java
index 16ab3577c..ed79b4cdc 100644
--- a/redisson/src/main/java/org/redisson/api/RStreamAsync.java
+++ b/redisson/src/main/java/org/redisson/api/RStreamAsync.java
@@ -59,6 +59,16 @@ public interface RStreamAsync<K, V> extends RExpirableAsync {
      */
     RFuture<Void> removeGroupAsync(String groupName);
 
+    /**
+     * Creates consumer of the group by name.
+     * <p>
+     * Requires <b>Redis 6.2.0 and higher.</b>
+     *
+     * @param groupName - name of group
+     * @param consumerName - name of consumer
+     */
+    RFuture<Void> createConsumerAsync(String groupName, String consumerName);
+
     /**
      * Removes consumer of the group by name.
      * 
diff --git a/redisson/src/main/java/org/redisson/api/RStreamReactive.java b/redisson/src/main/java/org/redisson/api/RStreamReactive.java
index 17b0840eb..f71fc9183 100644
--- a/redisson/src/main/java/org/redisson/api/RStreamReactive.java
+++ b/redisson/src/main/java/org/redisson/api/RStreamReactive.java
@@ -61,6 +61,16 @@ public interface RStreamReactive<K, V> extends RExpirableReactive {
      */
     Mono<Void> removeGroup(String groupName);
 
+    /**
+     * Creates consumer of the group by name.
+     * <p>
+     * Requires <b>Redis 6.2.0 and higher.</b>
+     *
+     * @param groupName - name of group
+     * @param consumerName - name of consumer
+     */
+    Mono<Void> createConsumer(String groupName, String consumerName);
+
     /**
      * Removes consumer of the group by name.
      * 
diff --git a/redisson/src/main/java/org/redisson/api/RStreamRx.java b/redisson/src/main/java/org/redisson/api/RStreamRx.java
index d6bd449fa..9fc3e9e4d 100644
--- a/redisson/src/main/java/org/redisson/api/RStreamRx.java
+++ b/redisson/src/main/java/org/redisson/api/RStreamRx.java
@@ -62,6 +62,16 @@ public interface RStreamRx<K, V> extends RExpirableRx {
      */
     Completable removeGroup(String groupName);
 
+    /**
+     * Creates consumer of the group by name.
+     * <p>
+     * Requires <b>Redis 6.2.0 and higher.</b>
+     *
+     * @param groupName - name of group
+     * @param consumerName - name of consumer
+     */
+    Completable createConsumer(String groupName, String consumerName);
+
     /**
      * Removes consumer of the group by name.
      *