Skip to content

Commit 2238a20

Browse files
committed
updating README.md
1 parent 3196f1c commit 2238a20

File tree

1 file changed

+16
-0
lines changed

1 file changed

+16
-0
lines changed

README.md

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -136,6 +136,22 @@ sleep(Duration::from_secs(10)).await;
136136
handle.close().await?;
137137
```
138138

139+
### Superstreams
140+
141+
The client supports the superstream functionality.
142+
143+
A super stream is a logical stream made of individual, regular streams. It is a way to scale out publishing and consuming with RabbitMQ Streams: a large logical stream is divided into partition streams, splitting up the storage and the traffic on several cluster nodes.
144+
145+
See the [blog post](https://blog.rabbitmq.com/posts/2022/07/rabbitmq-3-11-feature-preview-super-streams/) for more info.
146+
147+
You can use SuperStreamProducer and SuperStreamConsumer classes which internally uses producers and consumers to operate on the componsing streams.
148+
149+
Have a look to the examples to see on how to work with super streams.
150+
151+
See the [Super Stream Producer Example:](https://github.com/rabbitmq/rabbitmq-stream-rust-client/examples/send_super_stream.rs)
152+
153+
See the [Super Stream Consumer Example:](https://github.com/rabbitmq/rabbitmq-stream-rust-client/examples/receive_super_stream.rs)
154+
139155
### Development
140156

141157
#### Compiling

0 commit comments

Comments
 (0)