public class KafkaPublisher{
    private readonly IProducer<Null, string> _producer;

    public KafkaPublisher(string bootstrapServers) {
        var config = new ProducerConfig { BootstrapServers = bootstrapServers };
        _producer = new ProducerBuilder<Null, string>(config).Build();
    }

    public async Task PublishOrderPlacedAsync(OrderPlacedEvent orderPlaced) {
        var message = JsonSerializer.Serialize(orderPlaced);
        await _producer.ProduceAsync("order-events", new Message<Null, string> { Value = message });
    }
}

var retryPolicy = Policy
    .Handle<HttpRequestException>()
    .WaitAndRetryAsync(
        retryCount: 3,
        sleepDurationProvider: attempt => TimeSpan.FromSeconds(Math.Pow(2, attempt)),
        onRetry: (exception, timeSpan, retryCount, context) => {
            Console.WriteLine($"Retry {retryCount} sau {timeSpan.TotalSeconds}s vì: {exception.Message}");
        });

var circuitBreakerPolicy = Policy
    .Handle<HttpRequestException>()
    .CircuitBreakerAsync(
        exceptionsAllowedBeforeBreaking: 2,
        durationOfBreak: TimeSpan.FromSeconds(30),
        onBreak: (ex, breakDelay) => {
            Console.WriteLine($"Circuit breaker kích hoạt! Tạm dừng {breakDelay.TotalSeconds}s");
        },
        onReset: () => Console.WriteLine("Circuit breaker đóng, hoạt động trở lại."),
        onHalfOpen: () => Console.WriteLine("Circuit breaker bán mở, kiểm tra dịch vụ."));

var policyWrap = Policy.WrapAsync(retryPolicy, circuitBreakerPolicy);

var response = await policyWrap.ExecuteAsync(() =>
    httpClient.GetAsync("https://inventory-service/api/check-stock"));

public interface IInventoryService {
    Task<string> CheckStockAsync(string productId);
}

public class PrimaryInventoryService : IInventoryService {
    public async Task<string> CheckStockAsync(string productId) {
        throw new HttpRequestException("Dịch vụ chính không khả dụng");
    }
}

public class BackupInventoryService : IInventoryService {
    public async Task<string> CheckStockAsync(string productId) {
        return await Task.FromResult("Kho dự phòng: 10 đơn vị");
    }
}

var backupService = new BackupInventoryService();
var primaryService = new PrimaryInventoryService();

var fallbackPolicy = Policy<string>
    .Handle<HttpRequestException>()
    .FallbackAsync(
        fallbackAction: async cancellationToken => {
            Console.WriteLine("Dịch vụ chính lỗi. Chuyển sang kho dự phòng...");
            return await backupService.CheckStockAsync("P123");
        });

var result = await fallbackPolicy.ExecuteAsync(async () =>
{
    return await primaryService.CheckStockAsync("P123");
});

Console.WriteLine(result);