Found 54 packages
KafkaFlow main package
Contains all KafkaFlow extendable interfaces
Adapts KafkaFlow to use Microsoft Dependency Injection
Helper to run KafkaFlow as a Hosted Service
JSON implementation for KafkaFlow serializer middleware using System.Text.Json
Package Description
JSON implementation for KafkaFlow serializer middleware using Newtonsoft Json
Serializer middleware for KafkaFlow
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.
Allows KafkaFlow to use the Admin commands
Package Description
Protobuf implementation for KafkaFlow serializer middleware using Confluent.SchemaRegistry.Serdes.Protobuf package
Package Description
Avro implementation for KafkaFlow serializer middleware using Confluent.SchemaRegistry.Serdes.Avro package
Allows KafkaFlow to use the Admin Web API
Json implementation for KafkaFlow serializer middleware using Confluent.SchemaRegistry.Serdes.Json package