Implementing Horizontally Scalable Transactional Outbox Pattern with .NET 8 and Kafka: A Practical Guide

• SimpleTO

  1 0 4.3 C#

You can find the whole implementation by this link

• librdkafka

  1 7,252 - C

  Discontinued The Apache Kafka C/C++ library [Moved to: https://github.com/confluentinc/librdkafka] (by edenhill)

  

while (!stoppingToken.IsCancellationRequested) { try { var payloads = consumer.ConsumeBatch(TimeSpan.FromMinutes(1), _maxConsumeBatchSize, stoppingToken); if (payloads.Count == 0) continue; foreach (var payload in payloads) { var message = serializer.Deserialize(payload.Message.Value); foreach (var handler in messageHandlers) { await handler.HandleAsync(message, stoppingToken); } } consumer.Commit(); } catch (OperationCanceledException) { break; } catch (ConsumeException e) { if (e.Error.IsFatal) { // https://github.com/edenhill/librdkafka/blob/master/INTRODUCTION.md#fatal-consumer-errors logger.LogCritical(e, "Fatal error consuming message"); break; } else { logger.LogError(e, "Error consuming message"); } } catch (Exception e) { logger.LogError(e, "Error consuming message"); } }

• InfluxDB

  www.influxdata.com featured

  Power Real-Time Data Analytics at Scale. Get real-time insights from all types of time series data with InfluxDB. Ingest, query, and analyze billions of data points in real-time with unbounded cardinality.

  

Suggest a related project