this repo has no description
reduce the cursor
+1
-1
+1
-1
consumer.go
+1
-1
consumer.go
···
50
50
return fmt.Errorf("failed to create client: %w", err)
51
51
}
52
52
53
-
cursor := time.Now().Add(5 * -time.Minute).UnixMicro()
53
+
cursor := time.Now().Add(1 * -time.Minute).UnixMicro()
54
54
55
55
if err := c.ConnectAndRead(ctx, &cursor); err != nil {
56
56
return fmt.Errorf("connect and read: %w", err)