Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
fix: Use nondurable cursors for pulsar readers
By default we set subscriptions to use a durable cursor: https://github.com/streamnative/pulsar-rs/blob/master/PulsarApi.proto#L352 We only run into this when durable is None which can also be avoided if we use Pulsar::reader() which also sets durable to Some(false). However, there are cases where users may overwrite the options before calling `into_reader()`.
- Loading branch information