tkabsang 

A lightweight batch-processing framework for .NET. Declarative step-based pipelines with chunking, skip policies, and restart-from-failure support.

.NET Kafka consumer library with automatic retry, dead letter queue, offset management, and DLQ reprocessing. Implement IMessageHandler<TMessage> and the library handles everything else. Includes plain JSON... More information

Protobuf deserialization add-on for KafkaWorker. Adds AddKafkaWorkerProtobuf registration using Confluent Schema Registry. Requires the KafkaWorker package.

JSON Schema deserialization add-on for KafkaWorker. Adds AddKafkaWorkerRegistryJson registration using Confluent Schema Registry. Requires the KafkaWorker package.

Avro deserialization add-on for KafkaWorker. Adds AddKafkaWorkerAvro registration using Confluent Schema Registry. Requires the KafkaWorker package.

Entity Framework Core-based job store for NBatch. Provides SQL Server, PostgreSQL, SQLite, and MySQL/MariaDB support for persistent job tracking and restart-from-failure.