Farfetch 

Contains all KafkaFlow extendable interfaces

KafkaFlow main package

Adapts KafkaFlow to use Microsoft Dependency Injection

Package Description

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

Helper to run KafkaFlow as a Hosted Service

Serializer middleware for KafkaFlow

JSON implementation for KafkaFlow serializer middleware using Newtonsoft Json

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

LogHandler implementation leveraging Microsoft Logging framework.

Protobuf implementation for KafkaFlow serializer middleware using protobuf-net

Provides extensions methods to use Schema Registry

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

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

Package Description

Allows KafkaFlow to use the Admin commands

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