Replies: 1 comment
-
It seems that the push consumers are not suitable for this use case. |
Beta Was this translation helpful? Give feedback.
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
Hi
I have a strange behavior when using Push Consumers
I created them like this
I'm creating 10 queue subscribers like this
s.jetstreamContext.QueueSubscribe(s.streamName, fmt.Sprintf(GroupFormat, s.queueName), s.processTask, nats.Bind(s.streamName, s.consumerName))
, all of them using the same consumer.Each subscriber finishes its work in about 3 seconds.
The issue appears when I'm publishing 50 messages to the stream, the consumer is attached to. Even if I'm Acking the messages after finishing the work, the server resend me some of the published messages, resulting in duplicate work.
It might be this issue? Redelivery Of Acknowledged Messages or this is specific to STAN only and doesn't apply to JetStream?
Should I raise the AckWait time limit?
Thanks,
Tavi
Beta Was this translation helpful? Give feedback.
All reactions