asyncapi-python
asyncapi-python copied to clipboard
Issue with offsets when using asyncapi-subscriber
Hi. I have problems when using asyncapi-subsriber script. When started - it only consumes messages from that point in time. Older messages cant be consumed. For instance if consumer script dies, messages that were published while it was down wont be received. I tried setting offset in YAML ( to 0 for instance, while having groupId), but it had no effect. Am I doing something wrong, or it just doesn't support this? Also, is there way to manually acknowledge message within the consumer module operation methods (which asyncapi-subsriber uses next to YAML spec).
Thanks!