pulsar-client-dotnet

pulsar-client-dotnet copied to clipboard

Dead lock when consumer enable retry and call "isConnected" multiple times

2

Hello, thanks for your contribution，i found dead lock when i enable the retry option and call "isConnected" multiple times. And I have found the code that may potentially cause a...

Genuineh

Add support for Pulsar cluster level auto failover (PIP-121)

5

Please add support for cluster-level auto failover similar to Java client. Related information: [Cluster Level Fail Over PIP-121](https://github.com/apache/pulsar/issues/13315) [Java Client MR](https://github.com/apache/pulsar/pull/13316)

LeoSht

Schema with same class, record or enum for different fields throws error

1

Hi, we have a bug, that (at least for enums) we thought was fixed. If we use the same class, enum or record in different fields of a message like...

RufusK

Connection ist not reestablished after network or service Issue

8

Hi Lanayx, Thanhs for this great library to connect with a Pulsar cluster and make integrating this in .net so easy. Actually we have some issues while there are connection...

baumerik

Reference: https://github.com/apache/pulsar/pull/4299 API: https://github.com/apache/pulsar/blob/master/pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerBuilder.java#L397-L401

Akash98Sky

Add supported features to Pulsar Feature Matrix

5

Hi @Lanayx Thanks for making contributions to [pulsar-client-dotnet](https://github.com/fsprojects/pulsar-client-dotnet)! To show features supported by [pulsar-client-dotnet](https://github.com/fsprojects/pulsar-client-dotnet) to users more clearly, we (+@RobertIndie) have added both `code` and `doc` info to the [Pulsar...

Anonymitaet

Support FlushAsync in Producer

1

Producer can batch messages with SendAndForgetAsync, but has no way to flush. Example: ``` foreach (var message in messages) { await producer.SendAndForgetAsync(message); } await producer.FlushAsync() ```

DR9885

BatchReceivePolicy.maxNumMessages not working

8

Dear Author, I am currently utilizing the BatchReceiveAsync method in my project, and I've encountered an issue where the number of messages received exceeds the limit set by BatchReceivePolicy.maxNumMessages. Despite...

Myron5787

Check if the length of the received messages exceeds maxNumMessages

Myron5787

Table View is missing ForEachAndListen. I'd like to be able to subscribe to table view changes.

DR9885