Farfetch 

Contains all KafkaFlow extendable interfaces

KafkaFlow main package

Serializer middleware for KafkaFlow

Adapts KafkaFlow to use Microsoft Dependency Injection

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

Package Description

JSON implementation for KafkaFlow serializer middleware using Newtonsoft Json

Helper to run KafkaFlow as a Hosted Service

Protobuf implementation for KafkaFlow serializer middleware using protobuf-net

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

Allows KafkaFlow to use the Admin commands

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

Package Description

Allows KafkaFlow to use the Admin Web API

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

A KafkaFlow middleware to consume messages in batches

Compression middleware for KafkaFlow