Package io.simplesource.kafka.serialization.avro

Class AvroCommandSerdes<K,C>

java.lang.Object

io.simplesource.kafka.serialization.avro.AvroCommandSerdes<K,C>

All Implemented Interfaces:

io.simplesource.kafka.api.CommandSerdes<K,C>

public final class AvroCommandSerdes<K,C>
extends Object
implements io.simplesource.kafka.api.CommandSerdes<K,C>

Constructor Summary

Constructors

Constructor	Description
AvroCommandSerdes(GenericMapper<K,org.apache.avro.generic.GenericRecord> keyMapper, GenericMapper<C,org.apache.avro.generic.GenericRecord> commandMapper, String schemaRegistryUrl, boolean useMockSchemaRegistry)

Method Summary

Modifier and Type	Method	Description
org.apache.kafka.common.serialization.Serde<K>	aggregateKey()
org.apache.kafka.common.serialization.Serde<io.simplesource.kafka.model.CommandRequest<K,C>>	commandRequest()
org.apache.kafka.common.serialization.Serde<io.simplesource.kafka.model.CommandResponse>	commandResponse()
org.apache.kafka.common.serialization.Serde<UUID>	commandResponseKey()
static <K,C> AvroCommandSerdes<K,C>	of(GenericMapper<K,org.apache.avro.generic.GenericRecord> keyMapper, GenericMapper<C,org.apache.avro.generic.GenericRecord> commandMapper, String schemaRegistryUrl, boolean useMockSchemaRegistry)
static <K extends org.apache.avro.generic.GenericRecord,C extends org.apache.avro.generic.GenericRecord> AvroCommandSerdes<K,C>	of(String schemaRegistryUrl)
static <K extends org.apache.avro.generic.GenericRecord,C extends org.apache.avro.generic.GenericRecord> AvroCommandSerdes<K,C>	of(String schemaRegistryUrl, boolean useMockSchemaRegistry)

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroCommandSerdes

public AvroCommandSerdes(GenericMapper<K,org.apache.avro.generic.GenericRecord> keyMapper,
                         GenericMapper<C,org.apache.avro.generic.GenericRecord> commandMapper,
                         String schemaRegistryUrl,
                         boolean useMockSchemaRegistry)

Method Detail

of

public static <K extends org.apache.avro.generic.GenericRecord,C extends org.apache.avro.generic.GenericRecord> AvroCommandSerdes<K,C> of(String schemaRegistryUrl)

of

public static <K extends org.apache.avro.generic.GenericRecord,C extends org.apache.avro.generic.GenericRecord> AvroCommandSerdes<K,C> of(String schemaRegistryUrl,
                                                                                                                                          boolean useMockSchemaRegistry)

of

public static <K,C> AvroCommandSerdes<K,C> of(GenericMapper<K,org.apache.avro.generic.GenericRecord> keyMapper,
                                              GenericMapper<C,org.apache.avro.generic.GenericRecord> commandMapper,
                                              String schemaRegistryUrl,
                                              boolean useMockSchemaRegistry)

aggregateKey

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

Specified by:

aggregateKey in interface io.simplesource.kafka.api.CommandSerdes<K,C>

commandRequest

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

Specified by:

commandRequest in interface io.simplesource.kafka.api.CommandSerdes<K,C>

commandResponseKey

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

Specified by:

commandResponseKey in interface io.simplesource.kafka.api.CommandSerdes<K,C>

commandResponse

public org.apache.kafka.common.serialization.Serde<io.simplesource.kafka.model.CommandResponse> commandResponse()

Specified by:

commandResponse in interface io.simplesource.kafka.api.CommandSerdes<K,C>