2026-04-21 17:06:30,260 [109] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.YTOrderTrackAdd.v1] of stream [MCMS.Log.YTOrderTrackAdd] StackExchange.Redis.RedisTimeoutException: Timeout awaiting response (outbound=0KiB, inbound=0KiB, 3200ms elapsed, timeout is 3000ms), command=EXISTS, next: EXISTS MCMS.Log.ProductBatchInventoryLogBatchAdd, inst: 0, qu: 0, qs: 3, aw: False, bw: SpinningDown, rs: ReadAsync, ws: Idle, in: 0, in-pipe: 0, out-pipe: 0, last-in: 0, cur-in: 0, sync-ops: 0, async-ops: 21602656, serverEndpoint: 127.0.0.1:16379, conn-sec: 686684.16, aoc: 0, mc: 1/1/0, mgr: 10 of 10 available, clientName: DevelopmentServer(SE.Redis-v2.8.16.12844), IOCP: (Busy=0,Free=1000,Min=100,Max=1000), WORKER: (Busy=4,Free=32763,Min=100,Max=32767), POOL: (Threads=36,QueuedItems=0,CompletedItems=155439369,Timers=16), v: 2.8.16.12844 (Please take a look at this article for some common client-side issues that can cause timeouts: https://stackexchange.github.io/StackExchange.Redis/Timeouts) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:30,260 [512] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.ProductBatchInventoryLogBatchAdd.v1] of stream [MCMS.Log.ProductBatchInventoryLogBatchAdd] StackExchange.Redis.RedisTimeoutException: Timeout awaiting response (outbound=0KiB, inbound=0KiB, 3484ms elapsed, timeout is 3000ms), command=EXISTS, next: EXISTS MCMS.Log.ProductBatchInventoryLogBatchAdd, inst: 0, qu: 0, qs: 3, aw: False, bw: SpinningDown, rs: ReadAsync, ws: Idle, in: 0, in-pipe: 0, out-pipe: 0, last-in: 0, cur-in: 0, sync-ops: 0, async-ops: 21602656, serverEndpoint: 127.0.0.1:16379, conn-sec: 686684.15, aoc: 0, mc: 1/1/0, mgr: 10 of 10 available, clientName: DevelopmentServer(SE.Redis-v2.8.16.12844), IOCP: (Busy=0,Free=1000,Min=100,Max=1000), WORKER: (Busy=1,Free=32766,Min=100,Max=32767), POOL: (Threads=36,QueuedItems=0,CompletedItems=155439369,Timers=16), v: 2.8.16.12844 (Please take a look at this article for some common client-side issues that can cause timeouts: https://stackexchange.github.io/StackExchange.Redis/Timeouts) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:30,260 [193] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.DepponOrderTrackAdd.v1] of stream [MCMS.Log.DepponOrderTrackAdd] StackExchange.Redis.RedisTimeoutException: Timeout awaiting response (outbound=0KiB, inbound=0KiB, 3212ms elapsed, timeout is 3000ms), command=EXISTS, next: EXISTS MCMS.Log.ProductBatchInventoryLogBatchAdd, inst: 0, qu: 0, qs: 3, aw: False, bw: SpinningDown, rs: ReadAsync, ws: Idle, in: 0, in-pipe: 0, out-pipe: 0, last-in: 0, cur-in: 0, sync-ops: 0, async-ops: 21602656, serverEndpoint: 127.0.0.1:16379, conn-sec: 686684.16, aoc: 0, mc: 1/1/0, mgr: 10 of 10 available, clientName: DevelopmentServer(SE.Redis-v2.8.16.12844), IOCP: (Busy=0,Free=1000,Min=100,Max=1000), WORKER: (Busy=3,Free=32764,Min=100,Max=32767), POOL: (Threads=36,QueuedItems=0,CompletedItems=155439369,Timers=16), v: 2.8.16.12844 (Please take a look at this article for some common client-side issues that can cause timeouts: https://stackexchange.github.io/StackExchange.Redis/Timeouts) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:30,350 [287] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.ProductPurchaseOrderLogAdd.v1] of stream [MCMS.Log.ProductPurchaseOrderLogAdd] StackExchange.Redis.RedisTimeoutException: Timeout awaiting response (outbound=0KiB, inbound=0KiB, 3332ms elapsed, timeout is 3000ms), command=EXISTS, next: EXISTS MCMS.Log.JDOrderTrackBatchAdd, inst: 0, qu: 0, qs: 3, aw: False, bw: SpinningDown, rs: ReadAsync, ws: Idle, in: 0, in-pipe: 0, out-pipe: 0, last-in: 0, cur-in: 0, sync-ops: 0, async-ops: 15683549, serverEndpoint: 127.0.0.1:16379, conn-sec: 686684, aoc: 0, mc: 1/1/0, mgr: 10 of 10 available, clientName: DevelopmentServer(SE.Redis-v2.8.16.12844), IOCP: (Busy=0,Free=1000,Min=100,Max=1000), WORKER: (Busy=6,Free=32761,Min=100,Max=32767), POOL: (Threads=36,QueuedItems=0,CompletedItems=155439370,Timers=16), v: 2.8.16.12844 (Please take a look at this article for some common client-side issues that can cause timeouts: https://stackexchange.github.io/StackExchange.Redis/Timeouts) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:30,350 [347] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.OrderTrackAdd.v1] of stream [MCMS.Log.OrderTrackAdd] StackExchange.Redis.RedisTimeoutException: Timeout awaiting response (outbound=0KiB, inbound=0KiB, 3320ms elapsed, timeout is 3000ms), command=EXISTS, next: EXISTS MCMS.Log.JDOrderTrackBatchAdd, inst: 0, qu: 0, qs: 3, aw: False, bw: SpinningDown, rs: ReadAsync, ws: Idle, in: 0, in-pipe: 0, out-pipe: 0, last-in: 0, cur-in: 0, sync-ops: 0, async-ops: 15683549, serverEndpoint: 127.0.0.1:16379, conn-sec: 686684, aoc: 0, mc: 1/1/0, mgr: 10 of 10 available, clientName: DevelopmentServer(SE.Redis-v2.8.16.12844), IOCP: (Busy=0,Free=1000,Min=100,Max=1000), WORKER: (Busy=8,Free=32759,Min=100,Max=32767), POOL: (Threads=36,QueuedItems=0,CompletedItems=155439370,Timers=16), v: 2.8.16.12844 (Please take a look at this article for some common client-side issues that can cause timeouts: https://stackexchange.github.io/StackExchange.Redis/Timeouts) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:30,350 [651] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.JDOrderTrackBatchAdd.v1] of stream [MCMS.Log.JDOrderTrackBatchAdd] StackExchange.Redis.RedisTimeoutException: Timeout awaiting response (outbound=0KiB, inbound=0KiB, 3344ms elapsed, timeout is 3000ms), command=EXISTS, next: EXISTS MCMS.Log.JDOrderTrackBatchAdd, inst: 0, qu: 0, qs: 3, aw: False, bw: SpinningDown, rs: ReadAsync, ws: Idle, in: 0, in-pipe: 0, out-pipe: 0, last-in: 0, cur-in: 0, sync-ops: 0, async-ops: 15683549, serverEndpoint: 127.0.0.1:16379, conn-sec: 686684, aoc: 0, mc: 1/1/0, mgr: 10 of 10 available, clientName: DevelopmentServer(SE.Redis-v2.8.16.12844), IOCP: (Busy=0,Free=1000,Min=100,Max=1000), WORKER: (Busy=4,Free=32763,Min=100,Max=32767), POOL: (Threads=36,QueuedItems=0,CompletedItems=155439370,Timers=16), v: 2.8.16.12844 (Please take a look at this article for some common client-side issues that can cause timeouts: https://stackexchange.github.io/StackExchange.Redis/Timeouts) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:30,358 [221] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.PortalErrorLogAdd.v1] of stream [MCMS.Log.PortalErrorLogAdd] StackExchange.Redis.RedisTimeoutException: Timeout awaiting response (outbound=0KiB, inbound=0KiB, 3340ms elapsed, timeout is 3000ms), command=EXISTS, next: EXISTS MCMS.Log.ProductWarehouseEntryTrackLogAdd, inst: 0, qu: 0, qs: 3, aw: False, bw: SpinningDown, rs: ReadAsync, ws: Idle, in: 0, in-pipe: 0, out-pipe: 0, last-in: 0, cur-in: 0, sync-ops: 0, async-ops: 10580989, serverEndpoint: 127.0.0.1:16379, conn-sec: 686683, aoc: 0, mc: 1/1/0, mgr: 10 of 10 available, clientName: DevelopmentServer(SE.Redis-v2.8.16.12844), IOCP: (Busy=0,Free=1000,Min=100,Max=1000), WORKER: (Busy=9,Free=32758,Min=100,Max=32767), POOL: (Threads=36,QueuedItems=0,CompletedItems=155439371,Timers=16), v: 2.8.16.12844 (Please take a look at this article for some common client-side issues that can cause timeouts: https://stackexchange.github.io/StackExchange.Redis/Timeouts) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:30,359 [353] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.ProductWarehouseEntryTrackLogAdd.v1] of stream [MCMS.Log.ProductWarehouseEntryTrackLogAdd] StackExchange.Redis.RedisTimeoutException: Timeout awaiting response (outbound=0KiB, inbound=0KiB, 3352ms elapsed, timeout is 3000ms), command=EXISTS, next: EXISTS MCMS.Log.ProductWarehouseEntryTrackLogAdd, inst: 0, qu: 0, qs: 3, aw: False, bw: SpinningDown, rs: ReadAsync, ws: Idle, in: 0, in-pipe: 0, out-pipe: 0, last-in: 0, cur-in: 0, sync-ops: 0, async-ops: 10580989, serverEndpoint: 127.0.0.1:16379, conn-sec: 686683, aoc: 0, mc: 1/1/0, mgr: 10 of 10 available, clientName: DevelopmentServer(SE.Redis-v2.8.16.12844), IOCP: (Busy=0,Free=1000,Min=100,Max=1000), WORKER: (Busy=7,Free=32760,Min=100,Max=32767), POOL: (Threads=36,QueuedItems=0,CompletedItems=155439371,Timers=16), v: 2.8.16.12844 (Please take a look at this article for some common client-side issues that can cause timeouts: https://stackexchange.github.io/StackExchange.Redis/Timeouts) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:30,359 [433] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.CustomerInfoLogAdd.v1] of stream [MCMS.Log.CustomerInfoLogAdd] StackExchange.Redis.RedisTimeoutException: Timeout awaiting response (outbound=0KiB, inbound=0KiB, 3328ms elapsed, timeout is 3000ms), command=EXISTS, next: EXISTS MCMS.Log.ProductWarehouseEntryTrackLogAdd, inst: 0, qu: 0, qs: 3, aw: False, bw: SpinningDown, rs: ReadAsync, ws: Idle, in: 0, in-pipe: 0, out-pipe: 0, last-in: 0, cur-in: 0, sync-ops: 0, async-ops: 10580989, serverEndpoint: 127.0.0.1:16379, conn-sec: 686683, aoc: 0, mc: 1/1/0, mgr: 10 of 10 available, clientName: DevelopmentServer(SE.Redis-v2.8.16.12844), IOCP: (Busy=0,Free=1000,Min=100,Max=1000), WORKER: (Busy=10,Free=32757,Min=100,Max=32767), POOL: (Threads=36,QueuedItems=0,CompletedItems=155439371,Timers=16), v: 2.8.16.12844 (Please take a look at this article for some common client-side issues that can cause timeouts: https://stackexchange.github.io/StackExchange.Redis/Timeouts) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:30,363 [49] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.OrderReturnTrackAdd.v1] of stream [MCMS.Log.OrderReturnTrackAdd] StackExchange.Redis.RedisTimeoutException: Timeout awaiting response (outbound=0KiB, inbound=0KiB, 3340ms elapsed, timeout is 3000ms), command=EXISTS, next: EXISTS MCMS.Log.OperateLogBatchAdd, inst: 0, qu: 0, qs: 3, aw: False, bw: SpinningDown, rs: ReadAsync, ws: Idle, in: 0, in-pipe: 0, out-pipe: 0, last-in: 0, cur-in: 0, sync-ops: 0, async-ops: 5639810, serverEndpoint: 127.0.0.1:16379, conn-sec: 686682.01, aoc: 0, mc: 1/1/0, mgr: 10 of 10 available, clientName: DevelopmentServer(SE.Redis-v2.8.16.12844), IOCP: (Busy=0,Free=1000,Min=100,Max=1000), WORKER: (Busy=12,Free=32755,Min=100,Max=32767), POOL: (Threads=36,QueuedItems=0,CompletedItems=155439372,Timers=16), v: 2.8.16.12844 (Please take a look at this article for some common client-side issues that can cause timeouts: https://stackexchange.github.io/StackExchange.Redis/Timeouts) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:30,363 [55] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.OperateLogBatchAdd.v1] of stream [MCMS.Log.OperateLogBatchAdd] StackExchange.Redis.RedisTimeoutException: Timeout awaiting response (outbound=0KiB, inbound=0KiB, 3356ms elapsed, timeout is 3000ms), command=EXISTS, next: EXISTS MCMS.Log.OperateLogBatchAdd, inst: 0, qu: 0, qs: 3, aw: False, bw: SpinningDown, rs: ReadAsync, ws: Idle, in: 0, in-pipe: 0, out-pipe: 0, last-in: 0, cur-in: 0, sync-ops: 0, async-ops: 5639810, serverEndpoint: 127.0.0.1:16379, conn-sec: 686682.01, aoc: 0, mc: 1/1/0, mgr: 10 of 10 available, clientName: DevelopmentServer(SE.Redis-v2.8.16.12844), IOCP: (Busy=0,Free=1000,Min=100,Max=1000), WORKER: (Busy=11,Free=32756,Min=100,Max=32767), POOL: (Threads=36,QueuedItems=0,CompletedItems=155439372,Timers=16), v: 2.8.16.12844 (Please take a look at this article for some common client-side issues that can cause timeouts: https://stackexchange.github.io/StackExchange.Redis/Timeouts) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:30,363 [501] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.OrderRefundTrackAdd.v1] of stream [MCMS.Log.OrderRefundTrackAdd] StackExchange.Redis.RedisTimeoutException: Timeout awaiting response (outbound=0KiB, inbound=0KiB, 3332ms elapsed, timeout is 3000ms), command=EXISTS, next: EXISTS MCMS.Log.OperateLogBatchAdd, inst: 0, qu: 0, qs: 3, aw: False, bw: SpinningDown, rs: ReadAsync, ws: Idle, in: 0, in-pipe: 0, out-pipe: 0, last-in: 0, cur-in: 0, sync-ops: 0, async-ops: 5639810, serverEndpoint: 127.0.0.1:16379, conn-sec: 686682.01, aoc: 0, mc: 1/1/0, mgr: 10 of 10 available, clientName: DevelopmentServer(SE.Redis-v2.8.16.12844), IOCP: (Busy=0,Free=1000,Min=100,Max=1000), WORKER: (Busy=13,Free=32754,Min=100,Max=32767), POOL: (Threads=36,QueuedItems=0,CompletedItems=155439372,Timers=16), v: 2.8.16.12844 (Please take a look at this article for some common client-side issues that can cause timeouts: https://stackexchange.github.io/StackExchange.Redis/Timeouts) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:30,367 [223] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.JdSoOrderSyncLogFailedRetried.v1] of stream [MCMS.Log.JdSoOrderSyncLogFailedRetried] StackExchange.Redis.RedisTimeoutException: Timeout awaiting response (outbound=0KiB, inbound=0KiB, 3356ms elapsed, timeout is 3000ms), command=EXISTS, next: EXISTS MCMS.Log.JdSoOrderSyncLogFailedRetried, inst: 0, qu: 0, qs: 3, aw: False, bw: SpinningDown, rs: ReadAsync, ws: Idle, in: 0, in-pipe: 0, out-pipe: 0, last-in: 0, cur-in: 0, sync-ops: 0, async-ops: 2420062, serverEndpoint: 127.0.0.1:16379, conn-sec: 686682.01, aoc: 0, mc: 1/1/0, mgr: 10 of 10 available, clientName: DevelopmentServer(SE.Redis-v2.8.16.12844), IOCP: (Busy=0,Free=1000,Min=100,Max=1000), WORKER: (Busy=13,Free=32754,Min=100,Max=32767), POOL: (Threads=36,QueuedItems=0,CompletedItems=155439373,Timers=16), v: 2.8.16.12844 (Please take a look at this article for some common client-side issues that can cause timeouts: https://stackexchange.github.io/StackExchange.Redis/Timeouts) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:30,367 [226] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.ProductWarehouseEntryTrackLogBatchAdd.v1] of stream [MCMS.Log.ProductWarehouseEntryTrackLogBatchAdd] StackExchange.Redis.RedisTimeoutException: Timeout awaiting response (outbound=0KiB, inbound=0KiB, 3344ms elapsed, timeout is 3000ms), command=EXISTS, next: EXISTS MCMS.Log.JdSoOrderSyncLogFailedRetried, inst: 0, qu: 0, qs: 3, aw: False, bw: SpinningDown, rs: ReadAsync, ws: Idle, in: 0, in-pipe: 0, out-pipe: 0, last-in: 0, cur-in: 0, sync-ops: 0, async-ops: 2420062, serverEndpoint: 127.0.0.1:16379, conn-sec: 686682.01, aoc: 0, mc: 1/1/0, mgr: 10 of 10 available, clientName: DevelopmentServer(SE.Redis-v2.8.16.12844), IOCP: (Busy=0,Free=1000,Min=100,Max=1000), WORKER: (Busy=15,Free=32752,Min=100,Max=32767), POOL: (Threads=36,QueuedItems=0,CompletedItems=155439373,Timers=16), v: 2.8.16.12844 (Please take a look at this article for some common client-side issues that can cause timeouts: https://stackexchange.github.io/StackExchange.Redis/Timeouts) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:30,367 [465] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.ProductWarehouseOutTrackLogAdd.v1] of stream [MCMS.Log.ProductWarehouseOutTrackLogAdd] StackExchange.Redis.RedisTimeoutException: Timeout awaiting response (outbound=0KiB, inbound=0KiB, 3336ms elapsed, timeout is 3000ms), command=EXISTS, next: EXISTS MCMS.Log.JdSoOrderSyncLogFailedRetried, inst: 0, qu: 0, qs: 3, aw: False, bw: SpinningDown, rs: ReadAsync, ws: Idle, in: 0, in-pipe: 0, out-pipe: 0, last-in: 0, cur-in: 0, sync-ops: 0, async-ops: 2420062, serverEndpoint: 127.0.0.1:16379, conn-sec: 686682.01, aoc: 0, mc: 1/1/0, mgr: 10 of 10 available, clientName: DevelopmentServer(SE.Redis-v2.8.16.12844), IOCP: (Busy=0,Free=1000,Min=100,Max=1000), WORKER: (Busy=16,Free=32751,Min=100,Max=32767), POOL: (Threads=36,QueuedItems=0,CompletedItems=155439373,Timers=16), v: 2.8.16.12844 (Please take a look at this article for some common client-side issues that can cause timeouts: https://stackexchange.github.io/StackExchange.Redis/Timeouts) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:30,375 [3] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.SFOrderTrackAdd.v1] of stream [MCMS.Log.SFOrderTrackAdd] StackExchange.Redis.RedisTimeoutException: Timeout awaiting response (outbound=0KiB, inbound=0KiB, 3364ms elapsed, timeout is 3000ms), command=EXISTS, next: EXISTS MCMS.Log.SFOrderTrackAdd, inst: 0, qu: 0, qs: 3, aw: False, bw: SpinningDown, rs: ReadAsync, ws: Idle, in: 0, in-pipe: 0, out-pipe: 0, last-in: 0, cur-in: 0, sync-ops: 0, async-ops: 973476, serverEndpoint: 127.0.0.1:16379, conn-sec: 686681, aoc: 0, mc: 1/1/0, mgr: 10 of 10 available, clientName: DevelopmentServer(SE.Redis-v2.8.16.12844), IOCP: (Busy=0,Free=1000,Min=100,Max=1000), WORKER: (Busy=16,Free=32751,Min=100,Max=32767), POOL: (Threads=36,QueuedItems=0,CompletedItems=155439374,Timers=16), v: 2.8.16.12844 (Please take a look at this article for some common client-side issues that can cause timeouts: https://stackexchange.github.io/StackExchange.Redis/Timeouts) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:30,376 [554] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.OrderTrackBatchAdd.v1] of stream [MCMS.Log.OrderTrackBatchAdd] StackExchange.Redis.RedisTimeoutException: Timeout awaiting response (outbound=0KiB, inbound=0KiB, 3348ms elapsed, timeout is 3000ms), command=EXISTS, next: EXISTS MCMS.Log.SFOrderTrackAdd, inst: 0, qu: 0, qs: 3, aw: False, bw: SpinningDown, rs: ReadAsync, ws: Idle, in: 0, in-pipe: 0, out-pipe: 0, last-in: 0, cur-in: 0, sync-ops: 0, async-ops: 973476, serverEndpoint: 127.0.0.1:16379, conn-sec: 686681, aoc: 0, mc: 1/1/0, mgr: 10 of 10 available, clientName: DevelopmentServer(SE.Redis-v2.8.16.12844), IOCP: (Busy=0,Free=1000,Min=100,Max=1000), WORKER: (Busy=18,Free=32749,Min=100,Max=32767), POOL: (Threads=36,QueuedItems=0,CompletedItems=155439374,Timers=16), v: 2.8.16.12844 (Please take a look at this article for some common client-side issues that can cause timeouts: https://stackexchange.github.io/StackExchange.Redis/Timeouts) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:30,376 [470] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.ProductWarehouseOutTrackLogBatchAdd.v1] of stream [MCMS.Log.ProductWarehouseOutTrackLogBatchAdd] StackExchange.Redis.RedisTimeoutException: Timeout awaiting response (outbound=0KiB, inbound=0KiB, 3344ms elapsed, timeout is 3000ms), command=EXISTS, next: EXISTS MCMS.Log.SFOrderTrackAdd, inst: 0, qu: 0, qs: 3, aw: False, bw: SpinningDown, rs: ReadAsync, ws: Idle, in: 0, in-pipe: 0, out-pipe: 0, last-in: 0, cur-in: 0, sync-ops: 0, async-ops: 973476, serverEndpoint: 127.0.0.1:16379, conn-sec: 686681, aoc: 0, mc: 1/1/0, mgr: 10 of 10 available, clientName: DevelopmentServer(SE.Redis-v2.8.16.12844), IOCP: (Busy=0,Free=1000,Min=100,Max=1000), WORKER: (Busy=19,Free=32748,Min=100,Max=32767), POOL: (Threads=36,QueuedItems=0,CompletedItems=155439374,Timers=16), v: 2.8.16.12844 (Please take a look at this article for some common client-side issues that can cause timeouts: https://stackexchange.github.io/StackExchange.Redis/Timeouts) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:30,388 [280] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.PromotionTTClueConversionLogBatch.v1] of stream [MCMS.Log.PromotionTTClueConversionLogBatch] StackExchange.Redis.RedisTimeoutException: Timeout awaiting response (outbound=0KiB, inbound=0KiB, 3364ms elapsed, timeout is 3000ms), command=EXISTS, next: EXISTS MCMS.Log.QcCenterLogBatchAdd, inst: 0, qu: 0, qs: 3, aw: False, bw: SpinningDown, rs: ReadAsync, ws: Idle, in: 0, in-pipe: 0, out-pipe: 0, last-in: 0, cur-in: 0, sync-ops: 0, async-ops: 389689, serverEndpoint: 127.0.0.1:16379, conn-sec: 686679.01, aoc: 0, mc: 1/1/0, mgr: 10 of 10 available, clientName: DevelopmentServer(SE.Redis-v2.8.16.12844), IOCP: (Busy=0,Free=1000,Min=100,Max=1000), WORKER: (Busy=21,Free=32746,Min=100,Max=32767), POOL: (Threads=36,QueuedItems=0,CompletedItems=155439375,Timers=16), v: 2.8.16.12844 (Please take a look at this article for some common client-side issues that can cause timeouts: https://stackexchange.github.io/StackExchange.Redis/Timeouts) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:30,388 [541] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.QcCenterLogBatchAdd.v1] of stream [MCMS.Log.QcCenterLogBatchAdd] StackExchange.Redis.RedisTimeoutException: Timeout awaiting response (outbound=0KiB, inbound=0KiB, 3380ms elapsed, timeout is 3000ms), command=EXISTS, next: EXISTS MCMS.Log.QcCenterLogBatchAdd, inst: 0, qu: 0, qs: 3, aw: False, bw: SpinningDown, rs: ReadAsync, ws: Idle, in: 0, in-pipe: 0, out-pipe: 0, last-in: 0, cur-in: 0, sync-ops: 0, async-ops: 389689, serverEndpoint: 127.0.0.1:16379, conn-sec: 686679.01, aoc: 0, mc: 1/1/0, mgr: 10 of 10 available, clientName: DevelopmentServer(SE.Redis-v2.8.16.12844), IOCP: (Busy=0,Free=1000,Min=100,Max=1000), WORKER: (Busy=19,Free=32748,Min=100,Max=32767), POOL: (Threads=36,QueuedItems=0,CompletedItems=155439375,Timers=16), v: 2.8.16.12844 (Please take a look at this article for some common client-side issues that can cause timeouts: https://stackexchange.github.io/StackExchange.Redis/Timeouts) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:30,388 [646] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.OperateLog.v1] of stream [MCMS.Log.OperateLog] StackExchange.Redis.RedisTimeoutException: Timeout awaiting response (outbound=0KiB, inbound=0KiB, 3360ms elapsed, timeout is 3000ms), command=EXISTS, next: EXISTS MCMS.Log.QcCenterLogBatchAdd, inst: 0, qu: 0, qs: 3, aw: False, bw: SpinningDown, rs: ReadAsync, ws: Idle, in: 0, in-pipe: 0, out-pipe: 0, last-in: 0, cur-in: 0, sync-ops: 0, async-ops: 389689, serverEndpoint: 127.0.0.1:16379, conn-sec: 686679.01, aoc: 0, mc: 1/1/0, mgr: 10 of 10 available, clientName: DevelopmentServer(SE.Redis-v2.8.16.12844), IOCP: (Busy=0,Free=1000,Min=100,Max=1000), WORKER: (Busy=22,Free=32745,Min=100,Max=32767), POOL: (Threads=36,QueuedItems=0,CompletedItems=155439375,Timers=16), v: 2.8.16.12844 (Please take a look at this article for some common client-side issues that can cause timeouts: https://stackexchange.github.io/StackExchange.Redis/Timeouts) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:30,436 [647] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.JDOrderTrackAdd.v1] of stream [MCMS.Log.JDOrderTrackAdd] StackExchange.Redis.RedisTimeoutException: Timeout awaiting response (outbound=0KiB, inbound=0KiB, 3428ms elapsed, timeout is 3000ms), command=EXISTS, next: EXISTS MCMS.Log.JDOrderTrackAdd, inst: 0, qu: 0, qs: 3, aw: False, bw: SpinningDown, rs: ReadAsync, ws: Idle, in: 0, in-pipe: 0, out-pipe: 0, last-in: 353, cur-in: 0, sync-ops: 0, async-ops: 158311, serverEndpoint: 127.0.0.1:16379, conn-sec: 686654, aoc: 0, mc: 1/1/0, mgr: 10 of 10 available, clientName: DevelopmentServer(SE.Redis-v2.8.16.12844), IOCP: (Busy=0,Free=1000,Min=100,Max=1000), WORKER: (Busy=22,Free=32745,Min=100,Max=32767), POOL: (Threads=36,QueuedItems=0,CompletedItems=155439385,Timers=16), v: 2.8.16.12844 (Please take a look at this article for some common client-side issues that can cause timeouts: https://stackexchange.github.io/StackExchange.Redis/Timeouts) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:30,436 [487] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.ProductBatchInventoryLogAdd.v1] of stream [MCMS.Log.ProductBatchInventoryLogAdd] StackExchange.Redis.RedisTimeoutException: Timeout awaiting response (outbound=0KiB, inbound=0KiB, 3412ms elapsed, timeout is 3000ms), command=EXISTS, next: EXISTS MCMS.Log.JDOrderTrackAdd, inst: 0, qu: 0, qs: 3, aw: False, bw: SpinningDown, rs: ReadAsync, ws: Idle, in: 0, in-pipe: 0, out-pipe: 0, last-in: 353, cur-in: 0, sync-ops: 0, async-ops: 158311, serverEndpoint: 127.0.0.1:16379, conn-sec: 686654, aoc: 0, mc: 1/1/0, mgr: 10 of 10 available, clientName: DevelopmentServer(SE.Redis-v2.8.16.12844), IOCP: (Busy=0,Free=1000,Min=100,Max=1000), WORKER: (Busy=24,Free=32743,Min=100,Max=32767), POOL: (Threads=36,QueuedItems=0,CompletedItems=155439385,Timers=16), v: 2.8.16.12844 (Please take a look at this article for some common client-side issues that can cause timeouts: https://stackexchange.github.io/StackExchange.Redis/Timeouts) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:30,436 [392] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.QcCenterLogAdd.v1] of stream [MCMS.Log.QcCenterLogAdd] StackExchange.Redis.RedisTimeoutException: Timeout awaiting response (outbound=0KiB, inbound=0KiB, 3404ms elapsed, timeout is 3000ms), command=EXISTS, next: EXISTS MCMS.Log.JDOrderTrackAdd, inst: 0, qu: 0, qs: 3, aw: False, bw: SpinningDown, rs: ReadAsync, ws: Idle, in: 0, in-pipe: 0, out-pipe: 0, last-in: 353, cur-in: 0, sync-ops: 0, async-ops: 158311, serverEndpoint: 127.0.0.1:16379, conn-sec: 686654, aoc: 0, mc: 1/1/0, mgr: 10 of 10 available, clientName: DevelopmentServer(SE.Redis-v2.8.16.12844), IOCP: (Busy=0,Free=1000,Min=100,Max=1000), WORKER: (Busy=26,Free=32741,Min=100,Max=32767), POOL: (Threads=36,QueuedItems=0,CompletedItems=155439385,Timers=16), v: 2.8.16.12844 (Please take a look at this article for some common client-side issues that can cause timeouts: https://stackexchange.github.io/StackExchange.Redis/Timeouts) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:30,465 [256] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.CustomerInfoLogBatchAdd.v1] of stream [MCMS.Log.CustomerInfoLogBatchAdd] StackExchange.Redis.RedisTimeoutException: Timeout awaiting response (outbound=0KiB, inbound=0KiB, 3440ms elapsed, timeout is 3000ms), command=EXISTS, next: EXISTS MCMS.Log.JdSoOrderSyncLogAdd, inst: 0, qu: 0, qs: 2, aw: False, bw: SpinningDown, rs: ReadAsync, ws: Idle, in: 0, in-pipe: 0, out-pipe: 0, last-in: 353, cur-in: 0, sync-ops: 0, async-ops: 67459, serverEndpoint: 127.0.0.1:16379, conn-sec: 686648, aoc: 0, mc: 1/1/0, mgr: 10 of 10 available, clientName: DevelopmentServer(SE.Redis-v2.8.16.12844), IOCP: (Busy=0,Free=1000,Min=100,Max=1000), WORKER: (Busy=27,Free=32740,Min=100,Max=32767), POOL: (Threads=36,QueuedItems=0,CompletedItems=155439386,Timers=16), v: 2.8.16.12844 (Please take a look at this article for some common client-side issues that can cause timeouts: https://stackexchange.github.io/StackExchange.Redis/Timeouts) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:30,465 [302] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.JdSoOrderSyncLogAdd.v1] of stream [MCMS.Log.JdSoOrderSyncLogAdd] StackExchange.Redis.RedisTimeoutException: Timeout awaiting response (outbound=0KiB, inbound=0KiB, 3452ms elapsed, timeout is 3000ms), command=EXISTS, next: EXISTS MCMS.Log.JdSoOrderSyncLogAdd, inst: 0, qu: 0, qs: 2, aw: False, bw: SpinningDown, rs: ReadAsync, ws: Idle, in: 0, in-pipe: 0, out-pipe: 0, last-in: 353, cur-in: 0, sync-ops: 0, async-ops: 67459, serverEndpoint: 127.0.0.1:16379, conn-sec: 686648, aoc: 0, mc: 1/1/0, mgr: 10 of 10 available, clientName: DevelopmentServer(SE.Redis-v2.8.16.12844), IOCP: (Busy=0,Free=1000,Min=100,Max=1000), WORKER: (Busy=25,Free=32742,Min=100,Max=32767), POOL: (Threads=36,QueuedItems=0,CompletedItems=155439386,Timers=16), v: 2.8.16.12844 (Please take a look at this article for some common client-side issues that can cause timeouts: https://stackexchange.github.io/StackExchange.Redis/Timeouts) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:30,587 [594] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.PromotionTTClueConversionLog.v1] of stream [MCMS.Log.PromotionTTClueConversionLog] StackExchange.Redis.RedisTimeoutException: Timeout awaiting response (outbound=0KiB, inbound=0KiB, 3572ms elapsed, timeout is 3000ms), command=EXISTS, next: EXISTS MCMS.Log.PromotionTTClueConversionLog, inst: 0, qu: 0, qs: 2, aw: False, bw: SpinningDown, rs: ReadAsync, ws: Idle, in: 0, in-pipe: 0, out-pipe: 0, last-in: 353, cur-in: 0, sync-ops: 0, async-ops: 31229, serverEndpoint: 127.0.0.1:16379, conn-sec: 686602, aoc: 0, mc: 1/1/0, mgr: 10 of 10 available, clientName: DevelopmentServer(SE.Redis-v2.8.16.12844), IOCP: (Busy=0,Free=1000,Min=100,Max=1000), WORKER: (Busy=27,Free=32740,Min=100,Max=32767), POOL: (Threads=36,QueuedItems=0,CompletedItems=155439388,Timers=16), v: 2.8.16.12844 (Please take a look at this article for some common client-side issues that can cause timeouts: https://stackexchange.github.io/StackExchange.Redis/Timeouts) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:30,587 [176] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.PackagingPurchaseOrderLogAdd.v1] of stream [MCMS.Log.PackagingPurchaseOrderLogAdd] StackExchange.Redis.RedisTimeoutException: Timeout awaiting response (outbound=0KiB, inbound=0KiB, 3560ms elapsed, timeout is 3000ms), command=EXISTS, next: EXISTS MCMS.Log.PromotionTTClueConversionLog, inst: 0, qu: 0, qs: 2, aw: False, bw: SpinningDown, rs: ReadAsync, ws: Idle, in: 0, in-pipe: 0, out-pipe: 0, last-in: 353, cur-in: 0, sync-ops: 0, async-ops: 31229, serverEndpoint: 127.0.0.1:16379, conn-sec: 686602, aoc: 0, mc: 1/1/0, mgr: 10 of 10 available, clientName: DevelopmentServer(SE.Redis-v2.8.16.12844), IOCP: (Busy=0,Free=1000,Min=100,Max=1000), WORKER: (Busy=29,Free=32738,Min=100,Max=32767), POOL: (Threads=36,QueuedItems=0,CompletedItems=155439388,Timers=16), v: 2.8.16.12844 (Please take a look at this article for some common client-side issues that can cause timeouts: https://stackexchange.github.io/StackExchange.Redis/Timeouts) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,728 [594] ERROR DotNetCore.CAP.RedisStreams.AsyncLazyRedisConnection - Connection failed!, SocketFailure (ReadSocketError/ConnectionReset, 0-read, last-recv: 0) on 127.0.0.1:16379/Interactive, Flushed/Faulted, last: ECHO, origin: ReadFromPipe, outstanding: 13, last-read: 2s ago, last-write: 2s ago, unanswered-write: 2s ago, keep-alive: 60s, state: ConnectedEstablishing, mgr: 9 of 10 available, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844, for endpoint:127.0.0.1:16379, failure type:SocketFailure, connection type:Interactive StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, 0-read, last-recv: 0) on 127.0.0.1:16379/Interactive, Flushed/Faulted, last: ECHO, origin: ReadFromPipe, outstanding: 13, last-read: 2s ago, last-write: 2s ago, unanswered-write: 2s ago, keep-alive: 60s, state: ConnectedEstablishing, mgr: 9 of 10 available, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- 2026-04-21 17:06:32,897 [594] ERROR DotNetCore.CAP.RedisStreams.AsyncLazyRedisConnection - Connection failed!, SocketFailure (ReadSocketError/ConnectionReset, last-recv: 361) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 5, last-read: 11s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 5 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844, for endpoint:127.0.0.1:16379, failure type:SocketFailure, connection type:Interactive StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 361) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 5, last-read: 11s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 5 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,898 [3] ERROR DotNetCore.CAP.RedisStreams.AsyncLazyRedisConnection - Connection failed!, SocketFailure (ReadSocketError/ConnectionReset, last-recv: 5) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 6s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 1 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844, for endpoint:127.0.0.1:16379, failure type:SocketFailure, connection type:Interactive StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 5) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 6s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 1 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,899 [501] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.PromotionTTClueConversionLogBatch.v1] of stream [MCMS.Log.PromotionTTClueConversionLogBatch] StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 361) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 7s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 1 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,898 [256] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.QcCenterLogBatchAdd.v1] of stream [MCMS.Log.QcCenterLogBatchAdd] StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 361) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 5, last-read: 11s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 5 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,898 [647] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.OrderTrackBatchAdd.v1] of stream [MCMS.Log.OrderTrackBatchAdd] StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 5) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 6s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 1 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,902 [392] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.PortalErrorLogAdd.v1] of stream [MCMS.Log.PortalErrorLogAdd] StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 5) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 6s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 0 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,899 [594] ERROR DotNetCore.CAP.RedisStreams.AsyncLazyRedisConnection - Connection failed!, SocketFailure (ReadSocketError/ConnectionReset, last-recv: 361) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 7s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 1 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844, for endpoint:127.0.0.1:16379, failure type:SocketFailure, connection type:Interactive StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 361) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 7s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 1 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,899 [487] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.YTOrderTrackAdd.v1] of stream [MCMS.Log.YTOrderTrackAdd] StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 361) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 7s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 1 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,905 [408] ERROR DotNetCore.CAP.RedisStreams.AsyncLazyRedisConnection - Connection failed!, SocketFailure (ReadSocketError/ConnectionReset, last-recv: 5) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 6s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 0 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844, for endpoint:127.0.0.1:16379, failure type:SocketFailure, connection type:Interactive StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 5) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 6s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 0 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,900 [280] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.PackagingPurchaseOrderLogAdd.v1] of stream [MCMS.Log.PackagingPurchaseOrderLogAdd] StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 361) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 7s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 1 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,900 [554] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.OrderReturnTrackAdd.v1] of stream [MCMS.Log.OrderReturnTrackAdd] StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 361) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 7s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 1 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,908 [491] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.OrderTrackAdd.v1] of stream [MCMS.Log.OrderTrackAdd] StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 5) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 6s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 0 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,901 [302] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.ProductBatchInventoryLogBatchAdd.v1] of stream [MCMS.Log.ProductBatchInventoryLogBatchAdd] StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 361) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 5, last-read: 11s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 5 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,902 [226] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.CustomerInfoLogBatchAdd.v1] of stream [MCMS.Log.CustomerInfoLogBatchAdd] StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 5) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 6s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 0 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,898 [470] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.ProductWarehouseEntryTrackLogAdd.v1] of stream [MCMS.Log.ProductWarehouseEntryTrackLogAdd] StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 5) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 6s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 1 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,902 [176] ERROR DotNetCore.CAP.RedisStreams.AsyncLazyRedisConnection - Connection failed!, SocketClosed (ReadEndOfStream, last-recv: 0) on 127.0.0.1:16379/Subscription, Idle/MarkProcessed, last: PING, origin: ReadFromPipe, outstanding: 0, last-read: 0s ago, last-write: 45s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 0 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844, for endpoint:127.0.0.1:16379, failure type:SocketClosed, connection type:Subscription StackExchange.Redis.RedisConnectionException: SocketClosed (ReadEndOfStream, last-recv: 0) on 127.0.0.1:16379/Subscription, Idle/MarkProcessed, last: PING, origin: ReadFromPipe, outstanding: 0, last-read: 0s ago, last-write: 45s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 0 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 2026-04-21 17:06:32,902 [3] ERROR DotNetCore.CAP.RedisStreams.AsyncLazyRedisConnection - Connection failed!, SocketFailure (ReadSocketError/ConnectionReset, last-recv: 5) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 6s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 0 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844, for endpoint:127.0.0.1:16379, failure type:SocketFailure, connection type:Interactive StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 5) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 6s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 0 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,902 [465] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.SFOrderTrackAdd.v1] of stream [MCMS.Log.SFOrderTrackAdd] StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 5) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 6s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 0 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,903 [353] ERROR DotNetCore.CAP.RedisStreams.AsyncLazyRedisConnection - Connection failed!, SocketFailure (ReadSocketError/ConnectionReset, last-recv: 361) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 14s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 0 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844, for endpoint:127.0.0.1:16379, failure type:SocketFailure, connection type:Interactive StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 361) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 14s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 0 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,904 [651] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.PromotionTTClueConversionLog.v1] of stream [MCMS.Log.PromotionTTClueConversionLog] StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 361) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 14s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 0 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,904 [347] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.ProductWarehouseOutTrackLogBatchAdd.v1] of stream [MCMS.Log.ProductWarehouseOutTrackLogBatchAdd] StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 361) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 14s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 0 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,904 [49] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.CustomerInfoLogAdd.v1] of stream [MCMS.Log.CustomerInfoLogAdd] StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 361) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 14s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 0 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,905 [268] ERROR DotNetCore.CAP.RedisStreams.AsyncLazyRedisConnection - Connection failed!, SocketClosed (ReadEndOfStream, last-recv: 0) on 127.0.0.1:16379/Subscription, Idle/MarkProcessed, last: PING, origin: ReadFromPipe, outstanding: 0, last-read: 0s ago, last-write: 11s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 0 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844, for endpoint:127.0.0.1:16379, failure type:SocketClosed, connection type:Subscription StackExchange.Redis.RedisConnectionException: SocketClosed (ReadEndOfStream, last-recv: 0) on 127.0.0.1:16379/Subscription, Idle/MarkProcessed, last: PING, origin: ReadFromPipe, outstanding: 0, last-read: 0s ago, last-write: 11s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 0 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 2026-04-21 17:06:32,898 [646] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.OperateLogBatchAdd.v1] of stream [MCMS.Log.OperateLogBatchAdd] StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 361) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 5, last-read: 11s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 5 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,905 [221] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.QcCenterLogAdd.v1] of stream [MCMS.Log.QcCenterLogAdd] StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 5) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 6s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 0 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,905 [605] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.JDOrderTrackBatchAdd.v1] of stream [MCMS.Log.JDOrderTrackBatchAdd] StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 5) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 6s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 0 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,919 [227] ERROR DotNetCore.CAP.RedisStreams.AsyncLazyRedisConnection - Connection failed!, SocketClosed (ReadEndOfStream, last-recv: 0) on 127.0.0.1:16379/Subscription, Idle/MarkProcessed, last: PING, origin: ReadFromPipe, outstanding: 0, last-read: 0s ago, last-write: 51s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 9 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844, for endpoint:127.0.0.1:16379, failure type:SocketClosed, connection type:Subscription StackExchange.Redis.RedisConnectionException: SocketClosed (ReadEndOfStream, last-recv: 0) on 127.0.0.1:16379/Subscription, Idle/MarkProcessed, last: PING, origin: ReadFromPipe, outstanding: 0, last-read: 0s ago, last-write: 51s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 9 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 2026-04-21 17:06:32,906 [158] ERROR DotNetCore.CAP.RedisStreams.AsyncLazyRedisConnection - Connection failed!, SocketClosed (ReadEndOfStream, last-recv: 0) on 127.0.0.1:16379/Subscription, Idle/MarkProcessed, last: PING, origin: ReadFromPipe, outstanding: 0, last-read: 0s ago, last-write: 58s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 0 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844, for endpoint:127.0.0.1:16379, failure type:SocketClosed, connection type:Subscription StackExchange.Redis.RedisConnectionException: SocketClosed (ReadEndOfStream, last-recv: 0) on 127.0.0.1:16379/Subscription, Idle/MarkProcessed, last: PING, origin: ReadFromPipe, outstanding: 0, last-read: 0s ago, last-write: 58s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 0 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 2026-04-21 17:06:32,907 [177] ERROR DotNetCore.CAP.RedisStreams.AsyncLazyRedisConnection - Connection failed!, SocketClosed (ReadEndOfStream, last-recv: 0) on 127.0.0.1:16379/Subscription, Idle/MarkProcessed, last: PING, origin: ReadFromPipe, outstanding: 0, last-read: 0s ago, last-write: 13s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 0 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844, for endpoint:127.0.0.1:16379, failure type:SocketClosed, connection type:Subscription StackExchange.Redis.RedisConnectionException: SocketClosed (ReadEndOfStream, last-recv: 0) on 127.0.0.1:16379/Subscription, Idle/MarkProcessed, last: PING, origin: ReadFromPipe, outstanding: 0, last-read: 0s ago, last-write: 13s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 0 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 2026-04-21 17:06:32,908 [408] ERROR DotNetCore.CAP.RedisStreams.AsyncLazyRedisConnection - Connection failed!, SocketFailure (ReadSocketError/ConnectionReset, last-recv: 5) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 6s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 0 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844, for endpoint:127.0.0.1:16379, failure type:SocketFailure, connection type:Interactive StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 5) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 6s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 0 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,900 [541] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.JdSoOrderSyncLogAdd.v1] of stream [MCMS.Log.JdSoOrderSyncLogAdd] StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 5) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 6s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 1 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,909 [512] ERROR DotNetCore.CAP.RedisStreams.AsyncLazyRedisConnection - Connection failed!, SocketClosed (ReadEndOfStream, last-recv: 0) on 127.0.0.1:16379/Subscription, Idle/MarkProcessed, last: PING, origin: ReadFromPipe, outstanding: 0, last-read: 0s ago, last-write: 9s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 2 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844, for endpoint:127.0.0.1:16379, failure type:SocketClosed, connection type:Subscription StackExchange.Redis.RedisConnectionException: SocketClosed (ReadEndOfStream, last-recv: 0) on 127.0.0.1:16379/Subscription, Idle/MarkProcessed, last: PING, origin: ReadFromPipe, outstanding: 0, last-read: 0s ago, last-write: 9s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 2 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 2026-04-21 17:06:32,909 [109] ERROR DotNetCore.CAP.RedisStreams.AsyncLazyRedisConnection - Connection failed!, SocketClosed (ReadEndOfStream, last-recv: 0) on 127.0.0.1:16379/Subscription, Idle/MarkProcessed, last: PING, origin: ReadFromPipe, outstanding: 0, last-read: 0s ago, last-write: 39s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 2 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844, for endpoint:127.0.0.1:16379, failure type:SocketClosed, connection type:Subscription StackExchange.Redis.RedisConnectionException: SocketClosed (ReadEndOfStream, last-recv: 0) on 127.0.0.1:16379/Subscription, Idle/MarkProcessed, last: PING, origin: ReadFromPipe, outstanding: 0, last-read: 0s ago, last-write: 39s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 2 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 2026-04-21 17:06:32,909 [287] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.ProductBatchInventoryLogAdd.v1] of stream [MCMS.Log.ProductBatchInventoryLogAdd] StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 5) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 6s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 0 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,909 [594] ERROR DotNetCore.CAP.RedisStreams.AsyncLazyRedisConnection - Connection failed!, SocketClosed (ReadEndOfStream, last-recv: 0) on 127.0.0.1:16379/Subscription, Idle/MarkProcessed, last: PING, origin: ReadFromPipe, outstanding: 0, last-read: 0s ago, last-write: 38s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 1 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844, for endpoint:127.0.0.1:16379, failure type:SocketClosed, connection type:Subscription StackExchange.Redis.RedisConnectionException: SocketClosed (ReadEndOfStream, last-recv: 0) on 127.0.0.1:16379/Subscription, Idle/MarkProcessed, last: PING, origin: ReadFromPipe, outstanding: 0, last-read: 0s ago, last-write: 38s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 1 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 2026-04-21 17:06:32,909 [193] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.ProductWarehouseEntryTrackLogBatchAdd.v1] of stream [MCMS.Log.ProductWarehouseEntryTrackLogBatchAdd] StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 5) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 6s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 0 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,910 [223] ERROR DotNetCore.CAP.RedisStreams.AsyncLazyRedisConnection - Connection failed!, SocketFailure (ReadSocketError/ConnectionReset, last-recv: 5) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 6s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 1 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844, for endpoint:127.0.0.1:16379, failure type:SocketFailure, connection type:Interactive StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 5) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 6s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 1 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,913 [11] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.JdSoOrderSyncLogFailedRetried.v1] of stream [MCMS.Log.JdSoOrderSyncLogFailedRetried] StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 5) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 6s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 1 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,914 [391] ERROR DotNetCore.CAP.RedisStreams.AsyncLazyRedisConnection - Connection failed!, SocketClosed (ReadEndOfStream, last-recv: 0) on 127.0.0.1:16379/Subscription, Idle/MarkProcessed, last: PING, origin: ReadFromPipe, outstanding: 0, last-read: 0s ago, last-write: 14s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 6 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844, for endpoint:127.0.0.1:16379, failure type:SocketClosed, connection type:Subscription StackExchange.Redis.RedisConnectionException: SocketClosed (ReadEndOfStream, last-recv: 0) on 127.0.0.1:16379/Subscription, Idle/MarkProcessed, last: PING, origin: ReadFromPipe, outstanding: 0, last-read: 0s ago, last-write: 14s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 6 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 2026-04-21 17:06:32,914 [204] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.JDOrderTrackAdd.v1] of stream [MCMS.Log.JDOrderTrackAdd] StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 5) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 6s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 1 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,915 [352] ERROR DotNetCore.CAP.RedisStreams.AsyncLazyRedisConnection - Connection failed!, SocketFailure (ReadSocketError/ConnectionReset, last-recv: 5) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 6s ago, last-write: 1s ago, unanswered-write: 6s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 3 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844, for endpoint:127.0.0.1:16379, failure type:SocketFailure, connection type:Interactive StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 5) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 6s ago, last-write: 1s ago, unanswered-write: 6s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 3 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,917 [406] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.DepponOrderTrackAdd.v1] of stream [MCMS.Log.DepponOrderTrackAdd] StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 5) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 6s ago, last-write: 1s ago, unanswered-write: 6s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 3 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,918 [616] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.OrderRefundTrackAdd.v1] of stream [MCMS.Log.OrderRefundTrackAdd] StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 5) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 6s ago, last-write: 1s ago, unanswered-write: 6s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 3 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,917 [268] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.OperateLog.v1] of stream [MCMS.Log.OperateLog] StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 5) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 6s ago, last-write: 1s ago, unanswered-write: 6s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 3 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,918 [607] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.ProductPurchaseOrderLogAdd.v1] of stream [MCMS.Log.ProductPurchaseOrderLogAdd] StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 5) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 6s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 1 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:32,918 [471] ERROR DotNetCore.CAP.RedisStreams.AsyncLazyRedisConnection - Connection failed!, SocketClosed (ReadEndOfStream, last-recv: 0) on 127.0.0.1:16379/Subscription, Idle/MarkProcessed, last: PING, origin: ReadFromPipe, outstanding: 0, last-read: 0s ago, last-write: 8s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 8 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844, for endpoint:127.0.0.1:16379, failure type:SocketClosed, connection type:Subscription StackExchange.Redis.RedisConnectionException: SocketClosed (ReadEndOfStream, last-recv: 0) on 127.0.0.1:16379/Subscription, Idle/MarkProcessed, last: PING, origin: ReadFromPipe, outstanding: 0, last-read: 0s ago, last-write: 8s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 8 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 2026-04-21 17:06:32,905 [433] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.ProductWarehouseOutTrackLogAdd.v1] of stream [MCMS.Log.ProductWarehouseOutTrackLogAdd] StackExchange.Redis.RedisConnectionException: SocketFailure (ReadSocketError/ConnectionReset, last-recv: 5) on 127.0.0.1:16379/Interactive, Idle/Faulted, last: EXISTS, origin: ReadFromPipe, outstanding: 6, last-read: 6s ago, last-write: 1s ago, unanswered-write: 5s ago, keep-alive: 60s, state: ConnectedEstablished, mgr: 0 of 10 available, in: 0, in-pipe: 0, out-pipe: 0, last-heartbeat: 0s ago, last-mbeat: 0s ago, global: 0s ago, v: 2.8.16.12844 ---> Pipelines.Sockets.Unofficial.ConnectionResetException: Connection reset by peer ---> System.Net.Sockets.SocketException (104): Connection reset by peer at Pipelines.Sockets.Unofficial.Internal.Throw.Socket(Int32 errorCode) in /_/src/Pipelines.Sockets.Unofficial/Internal/Throw.cs:line 59 at Pipelines.Sockets.Unofficial.SocketAwaitableEventArgs.GetResult() in /_/src/Pipelines.Sockets.Unofficial/SocketAwaitableEventArgs.cs:line 74 at Pipelines.Sockets.Unofficial.SocketConnection.DoReceiveAsync() in /_/src/Pipelines.Sockets.Unofficial/SocketConnection.Receive.cs:line 64 --- End of inner exception stack trace --- at System.IO.Pipelines.Pipe.GetReadResult(ReadResult& result) at System.IO.Pipelines.Pipe.GetReadAsyncResult() at StackExchange.Redis.PhysicalConnection.ReadFromPipe() in /_/src/StackExchange.Redis/PhysicalConnection.cs:line 1886 --- End of inner exception stack trace --- at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:36,174 [.NET Signal Handler] INFO Startup - 【应用程序优雅关闭】 2026-04-21 17:06:36,214 [268] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.PromotionTTClueConversionLogBatch.v1] of stream [MCMS.Log.PromotionTTClueConversionLogBatch] System.ObjectDisposedException: Cannot access a disposed object. Object name: 'Connection is being disposed'. at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw() 2026-04-21 17:06:36,216 [406] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.JdSoOrderSyncLogAdd.v1] of stream [MCMS.Log.JdSoOrderSyncLogAdd] System.ObjectDisposedException: Cannot access a disposed object. Object name: 'Connection is being disposed'. at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:36,214 [226] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.OrderTrackAdd.v1] of stream [MCMS.Log.OrderTrackAdd] System.ObjectDisposedException: Cannot access a disposed object. Object name: 'Connection is being disposed'. at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:36,214 [11] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.SFOrderTrackAdd.v1] of stream [MCMS.Log.SFOrderTrackAdd] System.ObjectDisposedException: Cannot access a disposed object. Object name: 'Connection is being disposed'. at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:36,214 [433] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.YTOrderTrackAdd.v1] of stream [MCMS.Log.YTOrderTrackAdd] System.ObjectDisposedException: Cannot access a disposed object. Object name: 'Connection is being disposed'. at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:36,214 [287] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.QcCenterLogBatchAdd.v1] of stream [MCMS.Log.QcCenterLogBatchAdd] System.ObjectDisposedException: Cannot access a disposed object. Object name: 'Connection is being disposed'. at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:36,215 [392] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.PackagingPurchaseOrderLogAdd.v1] of stream [MCMS.Log.PackagingPurchaseOrderLogAdd] System.ObjectDisposedException: Cannot access a disposed object. Object name: 'Connection is being disposed'. at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:36,215 [408] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.OperateLog.v1] of stream [MCMS.Log.OperateLog] System.ObjectDisposedException: Cannot access a disposed object. Object name: 'Connection is being disposed'. at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:36,215 [204] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.OrderReturnTrackAdd.v1] of stream [MCMS.Log.OrderReturnTrackAdd] System.ObjectDisposedException: Cannot access a disposed object. Object name: 'Connection is being disposed'. at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:36,215 [347] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.PromotionTTClueConversionLog.v1] of stream [MCMS.Log.PromotionTTClueConversionLog] System.ObjectDisposedException: Cannot access a disposed object. Object name: 'Connection is being disposed'. at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:36,215 [487] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.OrderRefundTrackAdd.v1] of stream [MCMS.Log.OrderRefundTrackAdd] System.ObjectDisposedException: Cannot access a disposed object. Object name: 'Connection is being disposed'. at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:36,215 [256] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.OrderTrackBatchAdd.v1] of stream [MCMS.Log.OrderTrackBatchAdd] System.ObjectDisposedException: Cannot access a disposed object. Object name: 'Connection is being disposed'. at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:36,215 [280] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.ProductWarehouseOutTrackLogBatchAdd.v1] of stream [MCMS.Log.ProductWarehouseOutTrackLogBatchAdd] System.ObjectDisposedException: Cannot access a disposed object. Object name: 'Connection is being disposed'. at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:36,216 [646] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.ProductBatchInventoryLogBatchAdd.v1] of stream [MCMS.Log.ProductBatchInventoryLogBatchAdd] System.ObjectDisposedException: Cannot access a disposed object. Object name: 'Connection is being disposed'. at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:36,216 [594] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.ProductPurchaseOrderLogAdd.v1] of stream [MCMS.Log.ProductPurchaseOrderLogAdd] System.ObjectDisposedException: Cannot access a disposed object. Object name: 'Connection is being disposed'. at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:36,216 [647] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.PortalErrorLogAdd.v1] of stream [MCMS.Log.PortalErrorLogAdd] System.ObjectDisposedException: Cannot access a disposed object. Object name: 'Connection is being disposed'. at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:36,216 [616] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.JdSoOrderSyncLogFailedRetried.v1] of stream [MCMS.Log.JdSoOrderSyncLogFailedRetried] System.ObjectDisposedException: Cannot access a disposed object. Object name: 'Connection is being disposed'. at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:36,216 [541] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.CustomerInfoLogBatchAdd.v1] of stream [MCMS.Log.CustomerInfoLogBatchAdd] System.ObjectDisposedException: Cannot access a disposed object. Object name: 'Connection is being disposed'. at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:36,216 [651] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.QcCenterLogAdd.v1] of stream [MCMS.Log.QcCenterLogAdd] System.ObjectDisposedException: Cannot access a disposed object. Object name: 'Connection is being disposed'. at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:36,217 [554] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.CustomerInfoLogAdd.v1] of stream [MCMS.Log.CustomerInfoLogAdd] System.ObjectDisposedException: Cannot access a disposed object. Object name: 'Connection is being disposed'. at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:36,217 [302] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.ProductWarehouseEntryTrackLogBatchAdd.v1] of stream [MCMS.Log.ProductWarehouseEntryTrackLogBatchAdd] System.ObjectDisposedException: Cannot access a disposed object. Object name: 'Connection is being disposed'. at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:36,217 [501] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.ProductBatchInventoryLogAdd.v1] of stream [MCMS.Log.ProductBatchInventoryLogAdd] System.ObjectDisposedException: Cannot access a disposed object. Object name: 'Connection is being disposed'. at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:36,217 [49] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.ProductWarehouseOutTrackLogAdd.v1] of stream [MCMS.Log.ProductWarehouseOutTrackLogAdd] System.ObjectDisposedException: Cannot access a disposed object. Object name: 'Connection is being disposed'. at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:36,217 [605] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.JDOrderTrackBatchAdd.v1] of stream [MCMS.Log.JDOrderTrackBatchAdd] System.ObjectDisposedException: Cannot access a disposed object. Object name: 'Connection is being disposed'. at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:36,217 [471] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.DepponOrderTrackAdd.v1] of stream [MCMS.Log.DepponOrderTrackAdd] System.ObjectDisposedException: Cannot access a disposed object. Object name: 'Connection is being disposed'. at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:36,217 [465] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.OperateLogBatchAdd.v1] of stream [MCMS.Log.OperateLogBatchAdd] System.ObjectDisposedException: Cannot access a disposed object. Object name: 'Connection is being disposed'. at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:36,217 [491] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.JDOrderTrackAdd.v1] of stream [MCMS.Log.JDOrderTrackAdd] System.ObjectDisposedException: Cannot access a disposed object. Object name: 'Connection is being disposed'. at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() 2026-04-21 17:06:36,217 [470] ERROR DotNetCore.CAP.RedisStreams.RedisStreamManager - Redis error while creating consumer group [MCMS.Log.ProductWarehouseEntryTrackLogAdd.v1] of stream [MCMS.Log.ProductWarehouseEntryTrackLogAdd] System.ObjectDisposedException: Cannot access a disposed object. Object name: 'Connection is being disposed'. at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateStreamConsumerGroupAsync(IDatabase database, RedisKey stream, RedisValue consumerGroup) at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext() at DotNetCore.CAP.RedisStreams.RedisStreamManagerExtensions.TryGetOrCreateConsumerGroupPositionsAsync(IDatabase database, StreamPosition[] positions, String consumerGroup, ILogger logger)+MoveNext()