KafkaFlow.Serializer by Farfetch

<PackageReference Include="KafkaFlow.Serializer" Version="1.5.1" />

---

API Diff between 1.5.1 and 2.1.0-beta.8

26 Additions 5 Removals

KafkaFlow

• public static class ConfigurationBuilderExtensions
• public class DefaultMessageTypeResolver : IMessageTypeResolver
• public interface IMessageTypeResolver
• public class SerializerConsumerMiddleware : IMessageMiddleware
• public class SerializerProducerMiddleware : IMessageMiddleware

KafkaFlow.Serializer

• public static class ConfigurationBuilderExtensions
  • public static IConsumerMiddlewareConfigurationBuilder AddSerializer<TSerializer, TResolver>(this IConsumerMiddlewareConfigurationBuilder middlewares) where TSerializer : IMessageSerializer where TResolver : IMessageTypeResolver
  • public static IConsumerMiddlewareConfigurationBuilder AddSerializer<TSerializer, TResolver>(this IConsumerMiddlewareConfigurationBuilder middlewares, Factory<TSerializer> serializerFactory, Factory<TResolver> resolverFactory) where TSerializer : IMessageSerializer where TResolver : IMessageTypeResolver
  • public static IConsumerMiddlewareConfigurationBuilder AddSerializer<TSerializer>(this IConsumerMiddlewareConfigurationBuilder middlewares) where TSerializer : IMessageSerializer
  • public static IConsumerMiddlewareConfigurationBuilder AddSerializer<TSerializer>(this IConsumerMiddlewareConfigurationBuilder middlewares, Factory<TSerializer> serializerFactory) where TSerializer : IMessageSerializer
  • public static IProducerMiddlewareConfigurationBuilder AddSerializer<TSerializer, TResolver>(this IProducerMiddlewareConfigurationBuilder middlewares) where TSerializer : IMessageSerializer where TResolver : IMessageTypeResolver
  • public static IProducerMiddlewareConfigurationBuilder AddSerializer<TSerializer, TResolver>(this IProducerMiddlewareConfigurationBuilder middlewares, Factory<TSerializer> serializerFactory, Factory<TResolver> resolverFactory) where TSerializer : IMessageSerializer where TResolver : IMessageTypeResolver
  • public static IProducerMiddlewareConfigurationBuilder AddSerializer<TSerializer>(this IProducerMiddlewareConfigurationBuilder middlewares) where TSerializer : IMessageSerializer
  • public static IProducerMiddlewareConfigurationBuilder AddSerializer<TSerializer>(this IProducerMiddlewareConfigurationBuilder middlewares, Factory<TSerializer> serializerFactory) where TSerializer : IMessageSerializer
  • public static IConsumerMiddlewareConfigurationBuilder AddSingleTypeSerializer<TMessage, TSerializer>(this IConsumerMiddlewareConfigurationBuilder middlewares, Factory<TSerializer> serializerFactory) where TSerializer : IMessageSerializer
  • public static IConsumerMiddlewareConfigurationBuilder AddSingleTypeSerializer<TMessage, TSerializer>(this IConsumerMiddlewareConfigurationBuilder middlewares) where TSerializer : IMessageSerializer
  • public static IProducerMiddlewareConfigurationBuilder AddSingleTypeSerializer<TMessage, TSerializer>(this IProducerMiddlewareConfigurationBuilder middlewares, Factory<TSerializer> serializerFactory) where TSerializer : IMessageSerializer
  • public static IProducerMiddlewareConfigurationBuilder AddSingleTypeSerializer<TMessage, TSerializer>(this IProducerMiddlewareConfigurationBuilder middlewares) where TSerializer : IMessageSerializer
• public class DefaultMessageTypeResolver : IMessageTypeResolver
  • public DefaultMessageTypeResolver()
  • public Type OnConsume(IMessageContext context)
  • public void OnProduce(IMessageContext context)
• public interface IMessageTypeResolver
  • Type OnConsume(IMessageContext context)
  • void OnProduce(IMessageContext context)
• public class SerializerConsumerMiddleware : IMessageMiddleware
  • public SerializerConsumerMiddleware(IMessageSerializer serializer, IMessageTypeResolver typeResolver)
  • public Task Invoke(IMessageContext context, MiddlewareDelegate next)
• public class SerializerProducerMiddleware : IMessageMiddleware
  • public SerializerProducerMiddleware(IMessageSerializer serializer, IMessageTypeResolver typeResolver)
  • public Task Invoke(IMessageContext context, MiddlewareDelegate next)