Package | Description |
---|---|
io.simplesource.kafka.serialization.avro | |
io.simplesource.kafka.serialization.json | |
io.simplesource.kafka.serialization.util |
Modifier and Type | Class and Description |
---|---|
class |
AvroSpecificGenericMapper<D extends org.apache.avro.generic.GenericRecord> |
Modifier and Type | Method and Description |
---|---|
static <D extends org.apache.avro.generic.GenericRecord> |
AvroSpecificGenericMapper.specificDomainMapper() |
Modifier and Type | Method and Description |
---|---|
static <K,C> AvroCommandSerdes<K,C> |
AvroCommandSerdes.of(GenericMapper<K,org.apache.avro.generic.GenericRecord> keyMapper,
GenericMapper<C,org.apache.avro.generic.GenericRecord> commandMapper,
String schemaRegistryUrl,
boolean useMockSchemaRegistry) |
static <K,C> AvroCommandSerdes<K,C> |
AvroCommandSerdes.of(GenericMapper<K,org.apache.avro.generic.GenericRecord> keyMapper,
GenericMapper<C,org.apache.avro.generic.GenericRecord> commandMapper,
String schemaRegistryUrl,
boolean useMockSchemaRegistry) |
Constructor and Description |
---|
AvroAggregateSerdes(GenericMapper<K,org.apache.avro.generic.GenericRecord> keyMapper,
GenericMapper<C,org.apache.avro.generic.GenericRecord> commandMapper,
GenericMapper<E,org.apache.avro.generic.GenericRecord> eventMapper,
GenericMapper<A,org.apache.avro.generic.GenericRecord> aggregateMapper,
String schemaRegistryUrl,
boolean useMockSchemaRegistry,
org.apache.avro.Schema aggregateSchema) |
AvroAggregateSerdes(GenericMapper<K,org.apache.avro.generic.GenericRecord> keyMapper,
GenericMapper<C,org.apache.avro.generic.GenericRecord> commandMapper,
GenericMapper<E,org.apache.avro.generic.GenericRecord> eventMapper,
GenericMapper<A,org.apache.avro.generic.GenericRecord> aggregateMapper,
String schemaRegistryUrl,
boolean useMockSchemaRegistry,
org.apache.avro.Schema aggregateSchema) |
AvroAggregateSerdes(GenericMapper<K,org.apache.avro.generic.GenericRecord> keyMapper,
GenericMapper<C,org.apache.avro.generic.GenericRecord> commandMapper,
GenericMapper<E,org.apache.avro.generic.GenericRecord> eventMapper,
GenericMapper<A,org.apache.avro.generic.GenericRecord> aggregateMapper,
String schemaRegistryUrl,
boolean useMockSchemaRegistry,
org.apache.avro.Schema aggregateSchema) |
AvroAggregateSerdes(GenericMapper<K,org.apache.avro.generic.GenericRecord> keyMapper,
GenericMapper<C,org.apache.avro.generic.GenericRecord> commandMapper,
GenericMapper<E,org.apache.avro.generic.GenericRecord> eventMapper,
GenericMapper<A,org.apache.avro.generic.GenericRecord> aggregateMapper,
String schemaRegistryUrl,
boolean useMockSchemaRegistry,
org.apache.avro.Schema aggregateSchema) |
AvroCommandSerdes(GenericMapper<K,org.apache.avro.generic.GenericRecord> keyMapper,
GenericMapper<C,org.apache.avro.generic.GenericRecord> commandMapper,
String schemaRegistryUrl,
boolean useMockSchemaRegistry) |
AvroCommandSerdes(GenericMapper<K,org.apache.avro.generic.GenericRecord> keyMapper,
GenericMapper<C,org.apache.avro.generic.GenericRecord> commandMapper,
String schemaRegistryUrl,
boolean useMockSchemaRegistry) |
Modifier and Type | Class and Description |
---|---|
class |
JsonGenericMapper<D> |
class |
JsonOptionalGenericMapper<D> |
Modifier and Type | Method and Description |
---|---|
static <D> GenericMapper<D,com.google.gson.JsonElement> |
JsonGenericMapper.jsonDomainMapper() |
static <D> GenericMapper<Optional<D>,com.google.gson.JsonElement> |
JsonOptionalGenericMapper.jsonOptionalDomainMapper() |
Constructor and Description |
---|
JsonAggregateSerdes(GenericMapper<K,com.google.gson.JsonElement> keyMapper,
GenericMapper<C,com.google.gson.JsonElement> commandMapper,
GenericMapper<E,com.google.gson.JsonElement> eventMapper,
GenericMapper<A,com.google.gson.JsonElement> aggregateMapper) |
JsonAggregateSerdes(GenericMapper<K,com.google.gson.JsonElement> keyMapper,
GenericMapper<C,com.google.gson.JsonElement> commandMapper,
GenericMapper<E,com.google.gson.JsonElement> eventMapper,
GenericMapper<A,com.google.gson.JsonElement> aggregateMapper) |
JsonAggregateSerdes(GenericMapper<K,com.google.gson.JsonElement> keyMapper,
GenericMapper<C,com.google.gson.JsonElement> commandMapper,
GenericMapper<E,com.google.gson.JsonElement> eventMapper,
GenericMapper<A,com.google.gson.JsonElement> aggregateMapper) |
JsonAggregateSerdes(GenericMapper<K,com.google.gson.JsonElement> keyMapper,
GenericMapper<C,com.google.gson.JsonElement> commandMapper,
GenericMapper<E,com.google.gson.JsonElement> eventMapper,
GenericMapper<A,com.google.gson.JsonElement> aggregateMapper) |
JsonCommandSerdes(GenericMapper<K,com.google.gson.JsonElement> keyMapper,
GenericMapper<C,com.google.gson.JsonElement> commandMapper) |
JsonCommandSerdes(GenericMapper<K,com.google.gson.JsonElement> keyMapper,
GenericMapper<C,com.google.gson.JsonElement> commandMapper) |
Modifier and Type | Method and Description |
---|---|
static <A,S> org.apache.kafka.common.serialization.Serde<A> |
GenericSerde.of(org.apache.kafka.common.serialization.Serde<S> serde,
GenericMapper<A,S> mapper) |
Copyright © 2019. All rights reserved.