diff --git a/src/DotNetCore.CAP.RedisStreams/IRedisStream.Manager.Default.cs b/src/DotNetCore.CAP.RedisStreams/IRedisStream.Manager.Default.cs
index 03b3267e1..ba446a863 100644
--- a/src/DotNetCore.CAP.RedisStreams/IRedisStream.Manager.Default.cs
+++ b/src/DotNetCore.CAP.RedisStreams/IRedisStream.Manager.Default.cs
@@ -34,8 +34,8 @@ public async Task CreateStreamWithConsumerGroupAsync(string stream, string consu
 
             //The object returned from GetDatabase is a cheap pass - thru object, and does not need to be stored
             var database = _redis.GetDatabase();
-            var streamExist = await database.KeyTypeAsync(stream);
-            if (streamExist == RedisType.None)
+            var streamExist = await database.KeyExistsAsync(stream);
+            if (!streamExist)
             {
                 await database.StreamCreateConsumerGroupAsync(stream, consumerGroup, StreamPosition.NewMessages);
             }
diff --git a/src/DotNetCore.CAP.RedisStreams/IRedisStream.Manager.Extensions.cs b/src/DotNetCore.CAP.RedisStreams/IRedisStream.Manager.Extensions.cs
index 235a3a9b5..525026467 100644
--- a/src/DotNetCore.CAP.RedisStreams/IRedisStream.Manager.Extensions.cs
+++ b/src/DotNetCore.CAP.RedisStreams/IRedisStream.Manager.Extensions.cs
@@ -19,8 +19,8 @@ public static async IAsyncEnumerable<StreamPosition> TryCreateConsumerGroup(this
                 try
                 {
                     var stream = position.Key;
-                    var streamExist = await database.KeyTypeAsync(stream);
-                    if (streamExist == RedisType.None)
+                    var streamExist = await database.KeyExistsAsync(stream);
+                    if (!streamExist)
                     {
                         if (await database.StreamCreateConsumerGroupAsync(stream, consumerGroup,
                             StreamPosition.NewMessages))