This should allow users to change the initial position from the stream. I think there are way better ways but I was unable to see all of them. This should close #31, even though it's a mix of position in stream + shard check frequency, which takes up to 5 minutes in the default behavior to trigger.
Also, this tries to be compatible with the current behavior 100%.
This should allow users to change the initial position from the stream. I think there are way better ways but I was unable to see all of them. This should close #31, even though it's a mix of position in stream + shard check frequency, which takes up to 5 minutes in the default behavior to trigger.
Also, this tries to be compatible with the current behavior 100%.