Open Ivlyth opened 3 weeks ago
[root@xsiem bin]# nats consumer info
? Select a Stream event-base
? Select a Consumer actuator-transform
Information for Consumer event-base > actuator-transform created 2024-07-17T18:51:22+08:00
Configuration:
Name: actuator-transform
Pull Mode: true
Filter Subject: event-base.*
Deliver Policy: New
Ack Policy: Explicit
Ack Wait: 30.00s
Replay Policy: Instant
Max Ack Pending: 20,000
Max Waiting Pulls: 512
State:
Last Delivered Message: Consumer sequence: 1,890,922,977 Stream sequence: 2,358,770,804
Acknowledgment Floor: Consumer sequence: 1,890,907,977 Stream sequence: 2,358,755,804
Outstanding Acks: 15,000 out of maximum 20,000
Redelivered Messages: 0
Unprocessed Messages: 42,350,781
Waiting Pulls: 0 of maximum 512
[root@xsiem bin]# nats consumer report
? Select a Stream event-base
╭────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────╮
│ Consumer report for event-base with 1 consumers │
├────────────────────┬──────┬────────────┬──────────┬─────────────┬─────────────┬──────────────────┬───────────────┬─────────┤
│ Consumer │ Mode │ Ack Policy │ Ack Wait │ Ack Pending │ Redelivered │ Unprocessed │ Ack Floor │ Cluster │
├────────────────────┼──────┼────────────┼──────────┼─────────────┼─────────────┼──────────────────┼───────────────┼─────────┤
│ actuator-transform │ Pull │ Explicit │ 30.00s │ 15,000 │ 0 │ 42,350,781 / 52% │ 2,358,755,804 │ │
╰────────────────────┴──────┴────────────┴──────────┴─────────────┴─────────────┴──────────────────┴───────────────┴─────────╯
how about the nats stream info
from that consumer?
I delete the data directory after i post this issue.
below is the current stream info
[root@xsiem ~]# nats stream info
? Select a Stream event-base
Information for Stream event-base created 2024-08-20 15:13:36
Description: stream for event base (input)
Subjects: event-base.>
Replicas: 1
Storage: File
Options:
Retention: Limits
Acknowledgments: true
Discard Policy: Old
Duplicate Window: 2m0s
Allows Msg Delete: true
Allows Purge: true
Allows Rollups: false
Limits:
Maximum Messages: unlimited
Maximum Per Subject: unlimited
Maximum Bytes: 500 GiB
Maximum Age: unlimited
Maximum Message Size: unlimited
Maximum Consumers: unlimited
State:
Messages: 65,145,993
Bytes: 370 GiB
First Sequence: 1 @ 2024-08-20 15:14:03 UTC
Last Sequence: 65,145,993 @ 2024-08-20 17:02:38 UTC
Active Consumers: 1
Number of Subjects: 7
Observed behavior
in the log for version 2.10.7, we can see recovering consumer for stream event-transformed takes too long, about 5m30s and in the log for version 2.10.18, we can see the time is even long, it's about 7min
Expected behavior
when server restart, recovering the consumer not take so long
Server and client version
server: 2.10.7 and 2.10.18
Host environment
No response
Steps to reproduce
No response