Rstream

What's Changed

* Performance improvements during encoding of messages
* Increased connection timeout to 3 seconds
* Added examples on deduplication and superstreams key routing strategy

What's Changed

* Handle unexpected TCP disconnection in https://github.com/qweeze/rstream/issues/92
See the [documentation](https://github.com/qweeze/rstream#managing-disconnections)

What's Changed

* Performance improvements when producing using `send_sub_entry()` (see https://github.com/qweeze/rstream/issues/86)
* Added sub_entry_batch_example: https://github.com/qweeze/rstream/blob/master/docs/examples/sub_entry_batch/

What's Changed

* Performance improvements when producing using `send()` (see https://github.com/qweeze/rstream/issues/84)
* Add Examples: https://github.com/qweeze/rstream/tree/master/docs/examples

What's Changed

* Single active consumer implementation https://github.com/qweeze/rstream/pull/79
See [the blog post]( https://blog.rabbitmq.com/posts/2022/07/rabbitmq-3-11-feature-preview-single-active-consumer-for-streams/).
You can find an example [here](https://github.com/qweeze/rstream/tree/master/docs/examples/single_active_consumer)
* Manual tracking of stream offsets (`store_offset` to store offset to the server and `query_offset` to retrieve the offset from the server ): https://github.com/qweeze/rstream/issues/65
* Removed the work-in-progress label https://github.com/qweeze/rstream/pull/76

What's Changed

* Server side offset manual storing is now supported: See https://github.com/qweeze/rstream/issues/65 and https://github.com/qweeze/rstream/blob/master/docs/examples/manual_server_offset_tracking/consumer.py
* Improve performance for superstream producer using cache for ROUTE and PARTITION commands.