rabbitmq-stream-rust-client

rabbitmq-stream-rust-client copied to clipboard

Docker Image

2

Prepare a docker image to push in our pivotal docker hub to add clients in our LRE. We already have perf-test in GO and Java, so I would avoid to...

Gsantomaggio

`ClientOptions` should have a builder for configuring the `Client` We could use [type_builder](https://github.com/idanarye/rust-typed-builder) for automatically deriving the builder. The Builder should have an options for building the connection properties from...

wolf4ood

Route [command]

1

RouteQuery => Key Version CorrelationId RoutingKey SuperStream Key => uint16 // 24 Version => uint16 CorrelationId => uint32 RoutingKey => string SuperStream => string RouteResponse => Key Version CorrelationId Stream...

korsmakolnikov

Partitions [command]

1

PartitionsQuery => Key Version CorrelationId SuperStream Key => uint16 // 25 Version => uint16 CorrelationId => uint32 SuperStream => string PartitionsResponse => Key Version CorrelationId [Stream] Key => uint16 //...

korsmakolnikov

fixing bug when consuming from OffsetSpecification:Offset

2

This closes #222

DanielePalaia

Issue starting the Consumer from a given offset

2

### Describe the bug OffsetSpecification::Offset is sometimes working wrong: let stored_offset:u64 = 45; let mut consumer = environment .consumer() .name("consumer-1") .offset(OffsetSpecification::Offset(stored_offset)) .build(stream) .await .unwrap(); it is sometimes consuming from a...

DanielePalaia

Handle producer build for another port than 5552

1

### Describe the bug Hi, If I set another port than 5552 on rabbitmq environment, eg. 5000, the producer builder panics. It prints a connection refused on the build(stream): `Client(Io(Os...

Walfal

Bug/Doc: Producer connection refused if not using `.load_balancer_mode(true)`

3

### Describe the bug This is probably more an information to add to the doc/examples than a bug per say. A hint in the error message could also save some...

chevdor

When the server side is unexpectedly closed, the consumer cannot receive the error message and keeps sending heartbeats.

1

### Describe the bug When the server side is unexpectedly closed, the consumer cannot receive the error message and keeps sending heartbeats. ``` shell [2025-04-24T08:35:10Z TRACE rabbitmq_stream_client::consumer] Got delivery with...

JiaYingZhang

## 🤖 New release * `rabbitmq-stream-protocol`: 0.8.0 -> 0.8.1 (✓ API compatible changes) * `rabbitmq-stream-client`: 0.8.0 -> 0.9.0 (⚠ API breaking changes) ### ⚠ `rabbitmq-stream-client` breaking changes ```text --- failure...

github-actions[bot]