io.simplesource.kafka.api

Interface CommandSerdes<K,C>

Type Parameters:

K - the key type for aggregates, commands and events

C - base type of all commands for this aggregate

All Known Subinterfaces:

AggregateSerdes<K,C,E,A>

All Known Implementing Classes:

AvroAggregateSerdes, AvroCommandSerdes, JsonAggregateSerdes, JsonCommandSerdes

public interface 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. This interface provides support for the serialization requirements of the CommandAPI.

Method Summary

Modifier and Type	Method and Description
org.apache.kafka.common.serialization.Serde<K>	aggregateKey()
org.apache.kafka.common.serialization.Serde<CommandId>	commandId()
org.apache.kafka.common.serialization.Serde<CommandRequest<K,C>>	commandRequest()
org.apache.kafka.common.serialization.Serde<CommandResponse<K>>	commandResponse()

Method Detail

commandId

org.apache.kafka.common.serialization.Serde<CommandId> commandId()

aggregateKey

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

commandRequest

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

commandResponse

org.apache.kafka.common.serialization.Serde<CommandResponse<K>> commandResponse()