rueidis
rueidis copied to clipboard
stream read group when block 0
read group when block 0, will return context.DeadlineExceeded
xReadGroup = c.XReadGroup(context.Background(), XReadGroupArgs{
Group: "group",
Consumer: "consumer",
Streams: []string{key, ">"},
Block: 0,
})
fmt.Println(xReadGroup.Err())
Output:
context deadline exceeded
Hi @lenonqing,
Thank you for reporting this. This could take a couple of days.
Hi @lenonqing, this should be fixed in v0.0.70.
ok,thanks.