Supported pulsar cluster versions: 2.4+
Find examples of usage in /examples folder. We are trying to keep api similar to the Java client, so please take a look at it's documentation to understand possible options available. You can also join telegram chat https://t.me/pro_pulsar for further discussions.
Features list (from https://github.com/apache/pulsar/wiki/Client-Features-Matrix):
- Basic Producer/Consumer API
- Partitioned topics
- Batching
- Compression
- TLS
- Authentication (token-based)
- Reader API
- Proxy Support
- Effectively-Once
- Schema
- Consumer seek
- Multi-topics consumer
- Topics regex consumer
- Compacted topics
- User defined properties producer/consumer
- Reader hasMessageAvailable
- Hostname verification
- Multi Hosts Service Url support
- Key_shared
- key based batcher
- Negative Acknowledge
- Delayed Delivery Messages
- Dead Letter Policy
- Interceptors
- Fork and clone locally.
- Build the solution with
build.cmd
orbuild.sh
. (dotnet core sdk required) This will install required tools and then you can use any IDE to build solution - Make youre modifications
- Run Unit tests
- If changes are made in Client logic, run Integration tests. Before runnint do the following.
- Change
pulsarAddress
in Common.fs to point your pulsar cluster - Ensure
public/default
namespace with default settings - Ensure
public/retention
namespace with time or storage size retention configured
- Change
- Send a Pull Request.