DotPulsar Resiliency Extensions

Provides resiliency extensions for DotPulsar. This includes an implementation of dead letter queue as well as integration with Polly.

Installation

dotnet add package DotPulsar.Extensions.Resiliency

Usage

Using the DLQ implementation:

await using var dlq = new DeadLetterPolicy( client.NewProducer().Topic("...-DLQ"), client.NewProducer().Topic("...-RETRY")); ... await dlq.ReconsumeLater(message);

You will need to have a separate consumer set up to listen to the retry topic in order to process the retry messages. If those messages fail, then you will need to re-submit them to the DeadLetterPolicy to mark them as retry or dead.

Using Polly to create resilient producers:

await using var producer = client.NewProducer(Schema.String) .Topic("...") .CreateResilient(static pipeline => { pipeline.AddResilientProducerDefaults(configureRetry: static options => { options.MaxRetryAttempts = 3; }); });

License

This project is licensed under Apache License, Version 2.0.