rabbitmq-stream-dotnet-client

rabbitmq-stream-dotnet-client copied to clipboard

Data instances with a length of 255 bytes are wrongly written.

2

Hello, I've encountered a bug in the library. Messages which contain a Data instance with a size of exactly 255 bytes are written incorrectly. The cause of this is a...

Timz95

Error during close consumer during the delivery

1

Bug found by @ricsiLT When `consumer.close()` raises an exception when there are still some deliver frames on the network. Also, the client receives `throw new ArgumentException($"Unknown or unexpected tag: {tag}",...

Gsantomaggio

Work in progress Single Active Consumer

2

Work on this feature with @Zerpet Signed-off-by: Gabriele Santomaggio Closes https://github.com/rabbitmq/rabbitmq-stream-dotnet-client/issues/146 Note: `SacTests` will fail until the 3.11 is released

Gsantomaggio

Change reconnection logic in ReliableBase

5

In response to #150

ricsiLT

ReliableProducer not reconnecting after leader goes down

1

Hi, we observe that ReliableProducer does attempt to reconnect cluster after leader goes down. Our setup: * 3 node cluster (Node_A, Node_B, Node_C, let's say that Node_A is the leader)...

ricsiLT

Fix style in select classes to be more dotnet-like

1

Misc fixes related to style. Basically prefixing private variables in select classes with `_`.

ricardSiliuk

Add logging abstraction to use instead of ETW traces

1

Add an extra dependency to Microsoft Logging Abstractions so a logger can be passed into RMQ client. I'd argue that using LogEventSource looks out of place in more modern dotnet...

ricardSiliuk

Add Compression Codecs for sub-entry

6

By default client Support `None` and `GZIP`. We need to provide the examples for: ```csharp Snappy = 2, Lz4 = 3, Zstd = 4, ``` as external codec to be...

Gsantomaggio

Ref https://github.com/rabbitmq/rabbitmq-server/pull/5321 Per [internal conversion](https://vmware.slack.com/archives/C039S4USVPG/p1659086921580689)

Gsantomaggio

TimestampOffset

1

I have a stream which max age is 1 minute, and segment size is 50MB, when message size is around 25MB. In stream there are around 30 messages. I try...

suprunka