Use KeyExistsAsync for exists check (#1004)

Author: WeihanLi

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);
             }

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))