io.simplesource.kafka.serialization.avro

Class AvroAggregateSerdes<K,C,E,A>

java.lang.Object

io.simplesource.kafka.serialization.avro.AvroAggregateSerdes<K,C,E,A>

All Implemented Interfaces:

AggregateSerdes<K,C,E,A>

public final class AvroAggregateSerdes<K,C,E,A>
extends Object
implements AggregateSerdes<K,C,E,A>

Constructor Summary

Constructors

Constructor and Description
AvroAggregateSerdes(GenericMapper<A,org.apache.avro.generic.GenericRecord> aggregateMapper, GenericMapper<E,org.apache.avro.generic.GenericRecord> eventMapper, GenericMapper<C,org.apache.avro.generic.GenericRecord> commandMapper, GenericMapper<K,org.apache.avro.generic.GenericRecord> keyMapper, String schemaRegistryUrl, boolean useMockSchemaRegistry, org.apache.avro.Schema aggregateSchema)

Method Summary

Modifier and Type	Method and Description
org.apache.kafka.common.serialization.Serde<K>	aggregateKey()
org.apache.kafka.common.serialization.Serde<AggregateUpdate<A>>	aggregateUpdate()
org.apache.kafka.common.serialization.Serde<CommandRequest<C>>	commandRequest()
org.apache.kafka.common.serialization.Serde<UUID>	commandResponseKey()
static <A extends org.apache.avro.generic.GenericRecord,E extends org.apache.avro.generic.GenericRecord,C extends org.apache.avro.generic.GenericRecord,K extends org.apache.avro.generic.GenericRecord> AvroAggregateSerdes<A,E,C,K>	of(String schemaRegistryUrl, boolean useMockSchemaRegistry, org.apache.avro.Schema aggregateSchema)
static <A extends org.apache.avro.generic.GenericRecord,E extends org.apache.avro.generic.GenericRecord,C extends org.apache.avro.generic.GenericRecord,K extends org.apache.avro.generic.GenericRecord> AvroAggregateSerdes<A,E,C,K>	of(String schemaRegistryUrl, org.apache.avro.Schema aggregateSchema)
Map<String,Object>	serializerConfig()
org.apache.kafka.common.serialization.Serde<AggregateUpdateResult<A>>	updateResult()
org.apache.kafka.common.serialization.Serde<ValueWithSequence<E>>	valueWithSequence()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AvroAggregateSerdes

public AvroAggregateSerdes(GenericMapper<A,org.apache.avro.generic.GenericRecord> aggregateMapper,
                           GenericMapper<E,org.apache.avro.generic.GenericRecord> eventMapper,
                           GenericMapper<C,org.apache.avro.generic.GenericRecord> commandMapper,
                           GenericMapper<K,org.apache.avro.generic.GenericRecord> keyMapper,
                           String schemaRegistryUrl,
                           boolean useMockSchemaRegistry,
                           org.apache.avro.Schema aggregateSchema)

Method Detail

of

public static <A extends org.apache.avro.generic.GenericRecord,E extends org.apache.avro.generic.GenericRecord,C extends org.apache.avro.generic.GenericRecord,K extends org.apache.avro.generic.GenericRecord> AvroAggregateSerdes<A,E,C,K> of(String schemaRegistryUrl,
                                                                                                                                                                                                                                                org.apache.avro.Schema aggregateSchema)

of

public static <A extends org.apache.avro.generic.GenericRecord,E extends org.apache.avro.generic.GenericRecord,C extends org.apache.avro.generic.GenericRecord,K extends org.apache.avro.generic.GenericRecord> AvroAggregateSerdes<A,E,C,K> of(String schemaRegistryUrl,
                                                                                                                                                                                                                                                boolean useMockSchemaRegistry,
                                                                                                                                                                                                                                                org.apache.avro.Schema aggregateSchema)

aggregateKey

public org.apache.kafka.common.serialization.Serde<K> aggregateKey()

Specified by:

aggregateKey in interface AggregateSerdes<K,C,E,A>

commandRequest

public org.apache.kafka.common.serialization.Serde<CommandRequest<C>> commandRequest()

Specified by:

commandRequest in interface AggregateSerdes<K,C,E,A>

commandResponseKey

public org.apache.kafka.common.serialization.Serde<UUID> commandResponseKey()

Specified by:

commandResponseKey in interface AggregateSerdes<K,C,E,A>

valueWithSequence

public org.apache.kafka.common.serialization.Serde<ValueWithSequence<E>> valueWithSequence()

Specified by:

valueWithSequence in interface AggregateSerdes<K,C,E,A>

aggregateUpdate

public org.apache.kafka.common.serialization.Serde<AggregateUpdate<A>> aggregateUpdate()

Specified by:

aggregateUpdate in interface AggregateSerdes<K,C,E,A>

updateResult

public org.apache.kafka.common.serialization.Serde<AggregateUpdateResult<A>> updateResult()

Specified by:

updateResult in interface AggregateSerdes<K,C,E,A>

serializerConfig

public Map<String,Object> serializerConfig()

Specified by:

serializerConfig in interface AggregateSerdes<K,C,E,A>