Farfetch 

Contains all KafkaFlow extendable interfaces

KafkaFlow main package

Adapts KafkaFlow to use Microsoft Dependency Injection

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

Helper to run KafkaFlow as a Hosted Service

Package Description

JSON implementation for KafkaFlow serializer middleware using Newtonsoft Json

LogHandler implementation leveraging Microsoft Logging framework.

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

Provides extensions methods to use Schema Registry

Serializer middleware for KafkaFlow

Package Description

Protobuf implementation for KafkaFlow serializer middleware using protobuf-net

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

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

Allows KafkaFlow to use the Admin commands

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

Package Description

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

Allows KafkaFlow to use the Admin Web API