ConsumerBuilderExtensions class

A collection of convenience methods for ConsumerBuilder<,> that configure Avro deserializers.
AssemblyChr.Avro.Confluent
NamespaceChr.Avro.Confluent
Signature
public static class ConsumerBuilderExtensions
Baseobject

Methods

ConsumerBuilder<TKey, TValue> SetAvroKeyDeserializer<TKey, TValue>(ConsumerBuilder<TKey, TValue>, ISchemaRegistryClient)
Set the message key deserializer.
ConsumerBuilder<TKey, TValue> SetAvroKeyDeserializer<TKey, TValue>(ConsumerBuilder<TKey, TValue>, IEnumerable<KeyValuePair<string>>)
Set the message key deserializer.
Task<ConsumerBuilder<TKey, TValue>> SetAvroKeyDeserializer<TKey, TValue>(ConsumerBuilder<TKey, TValue>, ISchemaRegistryDeserializerBuilder, int)
Set the message key deserializer.
Task<ConsumerBuilder<TKey, TValue>> SetAvroKeyDeserializer<TKey, TValue>(ConsumerBuilder<TKey, TValue>, ISchemaRegistryDeserializerBuilder, string)
Set the message key deserializer.
Task<ConsumerBuilder<TKey, TValue>> SetAvroKeyDeserializer<TKey, TValue>(ConsumerBuilder<TKey, TValue>, ISchemaRegistryClient, int)
Set the message key deserializer.
Task<ConsumerBuilder<TKey, TValue>> SetAvroKeyDeserializer<TKey, TValue>(ConsumerBuilder<TKey, TValue>, ISchemaRegistryClient, string)
Set the message key deserializer.
Task<ConsumerBuilder<TKey, TValue>> SetAvroKeyDeserializer<TKey, TValue>(ConsumerBuilder<TKey, TValue>, IEnumerable<KeyValuePair<string>>, int)
Set the message key deserializer.
Task<ConsumerBuilder<TKey, TValue>> SetAvroKeyDeserializer<TKey, TValue>(ConsumerBuilder<TKey, TValue>, IEnumerable<KeyValuePair<string>>, string)
Set the message key deserializer.
Task<ConsumerBuilder<TKey, TValue>> SetAvroKeyDeserializer<TKey, TValue>(ConsumerBuilder<TKey, TValue>, ISchemaRegistryDeserializerBuilder, string, int)
Set the message key deserializer.
Task<ConsumerBuilder<TKey, TValue>> SetAvroKeyDeserializer<TKey, TValue>(ConsumerBuilder<TKey, TValue>, ISchemaRegistryClient, string, int)
Set the message key deserializer.
Task<ConsumerBuilder<TKey, TValue>> SetAvroKeyDeserializer<TKey, TValue>(ConsumerBuilder<TKey, TValue>, IEnumerable<KeyValuePair<string>>, string, int)
Set the message key deserializer.
ConsumerBuilder<TKey, TValue> SetAvroValueDeserializer<TKey, TValue>(ConsumerBuilder<TKey, TValue>, ISchemaRegistryClient, TombstoneBehavior)
Set the message value deserializer.
ConsumerBuilder<TKey, TValue> SetAvroValueDeserializer<TKey, TValue>(ConsumerBuilder<TKey, TValue>, IEnumerable<KeyValuePair<string>>, TombstoneBehavior)
Set the message value deserializer.
Task<ConsumerBuilder<TKey, TValue>> SetAvroValueDeserializer<TKey, TValue>(ConsumerBuilder<TKey, TValue>, ISchemaRegistryDeserializerBuilder, int, TombstoneBehavior)
Set the message value deserializer.
Task<ConsumerBuilder<TKey, TValue>> SetAvroValueDeserializer<TKey, TValue>(ConsumerBuilder<TKey, TValue>, ISchemaRegistryDeserializerBuilder, string, TombstoneBehavior)
Set the message value deserializer.
Task<ConsumerBuilder<TKey, TValue>> SetAvroValueDeserializer<TKey, TValue>(ConsumerBuilder<TKey, TValue>, ISchemaRegistryClient, int, TombstoneBehavior)
Set the message value deserializer.
Task<ConsumerBuilder<TKey, TValue>> SetAvroValueDeserializer<TKey, TValue>(ConsumerBuilder<TKey, TValue>, ISchemaRegistryClient, string, TombstoneBehavior)
Set the message value deserializer.
Task<ConsumerBuilder<TKey, TValue>> SetAvroValueDeserializer<TKey, TValue>(ConsumerBuilder<TKey, TValue>, IEnumerable<KeyValuePair<string>>, int, TombstoneBehavior)
Set the message value deserializer.
Task<ConsumerBuilder<TKey, TValue>> SetAvroValueDeserializer<TKey, TValue>(ConsumerBuilder<TKey, TValue>, IEnumerable<KeyValuePair<string>>, string, TombstoneBehavior)
Set the message value deserializer.
Task<ConsumerBuilder<TKey, TValue>> SetAvroValueDeserializer<TKey, TValue>(ConsumerBuilder<TKey, TValue>, ISchemaRegistryDeserializerBuilder, string, int, TombstoneBehavior)
Set the message value deserializer.
Task<ConsumerBuilder<TKey, TValue>> SetAvroValueDeserializer<TKey, TValue>(ConsumerBuilder<TKey, TValue>, ISchemaRegistryClient, string, int, TombstoneBehavior)
Set the message value deserializer.
Task<ConsumerBuilder<TKey, TValue>> SetAvroValueDeserializer<TKey, TValue>(ConsumerBuilder<TKey, TValue>, IEnumerable<KeyValuePair<string>>, string, int, TombstoneBehavior)
Set the message value deserializer.
Chr.Avro