pulsar-dotpulsar
pulsar-dotpulsar copied to clipboard
apache
The official .NET client library for Apache Pulsar
Why does "persistent://public/default/mytopic' changed state to 'Faulted" appear when I connect to the server version 2.10.0 No problem with pulas2.7.1
As mentioned in the keep alive section of the pulsar binary configuration [here](https://pulsar.apache.org/docs/v2.0.0-rc1-incubating/project/BinaryProtocol/) if the server stops responding to our pings when we have to assume the connection is no...
* feat: #45 `Consumer` now supports `NegativeAcknowledge` * add `AcknowledgementTimeout` to `ConsumerOptions` * add `NegativeAcknowledgementRedeliveryDelay` to `ConsumerOptions` * add `NegativeackedMessageState` to manage nacked messages * add `UnackedMessageState` to manage unacked...
Since https://github.com/apache/pulsar-dotpulsar/issues/6 has been closed, I'm creating this to track interest (in addition to https://github.com/apache/pulsar-dotpulsar/issues/6#issuecomment-988793327) and progress on Avro/JSON/Protobuf.
Let the consumer handle dead letters First design: #97 Feel free to add comments. Will work on it again after next week.
This PR adds support for the multi-topics consumer and partitioned consumer. Co-authored-by: Zike Yang Co-authored-by: Zixuan Liu
Once again thanks for the library! I just read up on pulsar end-to-end message encryption and I feel it should be among the ready made features. TLS connection is good;...
[NegativeAcknowledge](http://pulsar.apache.org/docs/en/concepts-messaging/#negative-acknowledgement) provides a nice way to shape error handling when messages cannot be processed and you want to do so at a later time with a given timeout: *Prefer negative...