Farfetch 

Contains all KafkaFlow extendable interfaces

KafkaFlow main package

Adapts KafkaFlow to use Microsoft Dependency Injection

Serializer middleware for KafkaFlow

Package Description

A KafkaFlow middleware to execute a handler class when a specific message arrives

Helper to run KafkaFlow as a Hosted Service

JSON implementation for KafkaFlow serializer middleware using System.Text.Json

JSON implementation for KafkaFlow serializer middleware using Newtonsoft Json

Protobuf implementation for KafkaFlow serializer middleware using protobuf-net

Provides extensions methods to use Schema Registry

LogHandler implementation leveraging Microsoft Logging framework.

An extension of KafkaFlow that adds retry capabilities to topic message consumers.

Protobuf implementation for KafkaFlow serializer middleware using Confluent.SchemaRegistry.Serdes.Protobuf package

Allows KafkaFlow to use the Admin commands

Package Description

Package Description

Avro implementation for KafkaFlow serializer middleware using Confluent.SchemaRegistry.Serdes.Avro package

Allows KafkaFlow to use the Admin Web API

A KafkaFlow middleware to consume messages in batches