DotPulsar 4.3.2-rc.1
DotPulsar
Let's take a look at a "Hello world" example, where we first set up a consumer and then produce a message. Note that the topic and subscription will be created if they don't exist.
Creating the client
Before creating readers, consumers, and producers, we need to create a client.
using DotPulsar;
using DotPulsar.Extensions;
await using var client = PulsarClient.Builder().Build(); // Connecting to pulsar://localhost:6650
Consuming
await using var consumer = client.NewConsumer(Schema.String)
.SubscriptionName("MySubscription")
.Topic("persistent://public/default/mytopic")
.InitialPosition(SubscriptionInitialPosition.Earliest)
.Create();
await foreach (var message in consumer.Messages())
{
Console.WriteLine($"Received: {message.Value()}");
await consumer.Acknowledge(message);
}
Producing
await using var producer = client.NewProducer(Schema.String).Topic("persistent://public/default/mytopic").Create();
var messageId = await producer.Send("Hello World");
No packages depend on DotPulsar.
Please refer to CHANGELOG.md for details
.NET 6.0
- HashDepot (>= 2.0.3)
- Microsoft.Extensions.ObjectPool (>= 9.0.9)
- System.IO.Pipelines (>= 8.0.0)
- protobuf-net (>= 3.2.56)
.NET 7.0
- HashDepot (>= 2.0.3)
- Microsoft.Extensions.ObjectPool (>= 9.0.9)
- System.IO.Pipelines (>= 8.0.0)
- protobuf-net (>= 3.2.56)
.NET 8.0
- HashDepot (>= 2.0.3)
- Microsoft.Extensions.ObjectPool (>= 9.0.9)
- System.IO.Pipelines (>= 9.0.9)
- protobuf-net (>= 3.2.56)
.NET 9.0
- HashDepot (>= 2.0.3)
- Microsoft.Extensions.ObjectPool (>= 9.0.9)
- System.IO.Pipelines (>= 9.0.9)
- protobuf-net (>= 3.2.56)
.NET Standard 2.0
- HashDepot (>= 2.0.3)
- Microsoft.Bcl.AsyncInterfaces (>= 9.0.9)
- Microsoft.Bcl.HashCode (>= 6.0.0)
- Microsoft.Extensions.ObjectPool (>= 9.0.9)
- System.Diagnostics.DiagnosticSource (>= 9.0.9)
- System.IO.Pipelines (>= 8.0.0)
- protobuf-net (>= 3.2.56)
.NET Standard 2.1
- HashDepot (>= 2.0.3)
- Microsoft.Extensions.ObjectPool (>= 9.0.9)
- System.Diagnostics.DiagnosticSource (>= 9.0.9)
- System.IO.Pipelines (>= 8.0.0)
- protobuf-net (>= 3.2.56)
| Version | Downloads | Last updated |
|---|---|---|
| 5.1.1 | 0 | 2025/12/12 |
| 5.1.1-rc.1 | 0 | 2025/12/10 |
| 5.1.0 | 0 | 2025/11/24 |
| 5.1.0-rc.1 | 2 | 2025/11/19 |
| 5.0.0 | 2 | 2025/11/19 |
| 5.0.0-rc.1 | 1 | 2025/11/19 |
| 5.0.0-alpha.1 | 1 | 2025/11/19 |
| 4.3.2 | 1 | 2025/11/19 |
| 4.3.2-rc.1 | 1 | 2025/11/19 |
| 4.3.1 | 1 | 2025/11/19 |
| 4.3.1-rc.1 | 1 | 2025/11/19 |
| 4.3.0 | 1 | 2025/11/19 |
| 4.3.0-rc.1 | 1 | 2025/11/19 |
| 4.2.4 | 1 | 2025/11/19 |
| 4.2.3 | 1 | 2025/11/19 |
| 4.2.3-rc.1 | 1 | 2025/11/19 |
| 4.2.2 | 1 | 2025/11/19 |
| 4.2.1 | 1 | 2025/11/19 |
| 4.2.1-rc.1 | 1 | 2025/11/19 |
| 4.2.0 | 1 | 2025/11/19 |
| 4.2.0-rc.1 | 1 | 2025/11/19 |
| 4.1.0 | 1 | 2025/11/19 |
| 4.1.0-rc.1 | 1 | 2025/11/19 |
| 4.0.0 | 1 | 2025/11/19 |
| 4.0.0-rc.1 | 1 | 2025/11/19 |
| 3.6.0 | 1 | 2025/11/19 |
| 3.6.0-rc.1 | 1 | 2025/11/19 |
| 3.5.0 | 1 | 2025/11/19 |
| 3.5.0-rc.1 | 1 | 2025/11/19 |
| 3.4.0 | 1 | 2025/11/19 |
| 3.4.0-rc.1 | 1 | 2025/11/19 |
| 3.3.2 | 1 | 2025/11/19 |
| 3.3.2-rc.1 | 1 | 2025/11/19 |
| 3.3.1 | 1 | 2025/11/19 |
| 3.3.1-rc.1 | 1 | 2025/11/19 |
| 3.3.0 | 1 | 2025/11/19 |
| 3.3.0-rc.1 | 1 | 2025/11/19 |
| 3.2.1 | 1 | 2025/11/19 |
| 3.2.1-rc.1 | 1 | 2025/11/19 |
| 3.2.0 | 1 | 2025/11/19 |
| 3.2.0-rc.1 | 1 | 2025/11/19 |
| 3.1.2 | 1 | 2025/11/19 |
| 3.1.2-rc.1 | 1 | 2025/11/19 |
| 3.1.1 | 2 | 2025/11/19 |
| 3.1.1-rc.1 | 1 | 2025/11/19 |
| 3.1.0 | 1 | 2025/11/19 |
| 3.1.0-rc.1 | 1 | 2025/11/19 |
| 3.0.2 | 1 | 2025/11/19 |
| 3.0.1 | 1 | 2025/11/19 |
| 3.0.0 | 1 | 2025/11/19 |
| 2.11.1 | 1 | 2025/11/19 |
| 2.11.0 | 1 | 2025/11/19 |
| 2.10.2 | 1 | 2025/11/19 |
| 2.10.1 | 1 | 2025/11/19 |
| 2.10.0 | 1 | 2025/11/19 |
| 2.9.0 | 1 | 2025/11/19 |
| 2.8.0 | 1 | 2025/11/19 |
| 2.7.0 | 1 | 2025/11/19 |
| 2.6.0 | 1 | 2025/11/19 |
| 2.5.2 | 1 | 2025/11/19 |
| 2.5.1 | 1 | 2025/11/19 |
| 2.5.0 | 1 | 2025/11/19 |
| 2.4.1 | 1 | 2025/11/19 |
| 2.4.0 | 1 | 2025/11/19 |
| 2.3.1 | 1 | 2025/11/19 |
| 2.3.0 | 1 | 2025/11/19 |
| 2.2.0 | 1 | 2025/11/19 |
| 2.1.0 | 1 | 2025/11/19 |
| 2.0.1 | 1 | 2025/11/19 |
| 1.1.2 | 1 | 2025/11/19 |
| 1.1.1 | 1 | 2025/11/19 |
| 1.1.0 | 1 | 2025/11/19 |
| 1.0.2 | 1 | 2025/11/19 |
| 1.0.1 | 1 | 2025/11/19 |
| 1.0.0 | 1 | 2025/11/19 |
| 0.11.0 | 1 | 2025/11/19 |
| 0.10.1 | 1 | 2025/11/19 |
| 0.10.0 | 1 | 2025/11/19 |
| 0.9.7 | 1 | 2025/11/19 |
| 0.9.6 | 1 | 2025/11/19 |
| 0.9.5 | 1 | 2025/11/19 |
| 0.9.4 | 1 | 2025/11/19 |
| 0.9.3 | 1 | 2025/11/19 |
| 0.9.2 | 1 | 2025/11/19 |
| 0.9.1 | 1 | 2025/11/19 |
| 0.9.0 | 1 | 2025/11/19 |
| 0.8.4 | 1 | 2025/11/19 |
| 0.8.3 | 1 | 2025/11/19 |
| 0.8.2 | 1 | 2025/11/19 |
| 0.8.1 | 1 | 2025/11/19 |
| 0.8.0 | 1 | 2025/11/19 |
| 0.7.2 | 1 | 2025/11/19 |
| 0.7.1 | 1 | 2025/11/19 |
| 0.7.0 | 1 | 2025/11/19 |
| 0.6.0 | 1 | 2025/11/19 |
| 0.5.0 | 1 | 2025/11/19 |
| 0.4.0 | 1 | 2025/11/19 |
| 0.3.0 | 1 | 2025/11/19 |
| 0.2.0 | 1 | 2025/11/19 |
| 0.1.3 | 1 | 2025/11/19 |
| 0.1.2 | 1 | 2025/11/19 |
| 0.1.1 | 1 | 2025/11/19 |
| 0.1.0 | 1 | 2025/11/19 |