io.simplesource.kafka.api

Interface AggregateSerdes<K,C,E,A>

Type Parameters:

K - the key type for aggregates, commands and events

C - base type of all commands for this aggregate

E - base type of all events generated for this aggregate

A - the aggregate aggregate_update

All Superinterfaces:

CommandSerdes<K,C>

All Known Implementing Classes:

AvroAggregateSerdes, JsonAggregateSerdes

public interface AggregateSerdes<K,C,E,A>
extends CommandSerdes<K,C>

Responsible for providing the mechanism for reading and writing to Kafka from the Simple Sourcing Kafka Streams application when using the given serialization class. A single instance of this class should support all aggregators that wish to persist using the given serialization type. See separate serialization modules for bundled Avro and JSON implementations. Most Simple Sourcing users should be able to use an out-of-the-box implementation rather than writing their own.

Method Summary

Modifier and Type	Method and Description
org.apache.kafka.common.serialization.Serde<AggregateUpdate<A>>	aggregateUpdate()
org.apache.kafka.common.serialization.Serde<ValueWithSequence<E>>	valueWithSequence()

Methods inherited from interface io.simplesource.kafka.api.CommandSerdes

aggregateKey, commandId, commandRequest, commandResponse

Method Detail

valueWithSequence

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

aggregateUpdate

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