| Modifier and Type | Class | Description |
|---|---|---|
class |
AvroSpecificGenericMapper<D extends org.apache.avro.generic.GenericRecord> |
| Modifier and Type | Method | Description |
|---|---|---|
static <D extends org.apache.avro.generic.GenericRecord> |
AvroSpecificGenericMapper.specificDomainMapper() |
| Modifier and Type | Method | 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) |
| Constructor | 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) |
|
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 | Description |
|---|---|---|
class |
RegistryBasedDomainMapper<V,S extends org.apache.avro.generic.GenericRecord> |
Domain mapper implementation using registry for all supported domain-serialized class combinations
|
| Modifier and Type | Method | Description |
|---|---|---|
<D,A extends org.apache.avro.generic.GenericRecord> |
DomainMapperBuilder.build() |
|
<D,A extends org.apache.avro.generic.GenericRecord> |
DomainMapperBuilder.build(GenericMapper<A,org.apache.avro.generic.GenericRecord> avroSpecificGenericMapper) |
| Modifier and Type | Method | Description |
|---|---|---|
<D,A extends org.apache.avro.generic.GenericRecord> |
DomainMapperBuilder.build(GenericMapper<A,org.apache.avro.generic.GenericRecord> avroSpecificGenericMapper) |
| Modifier and Type | Class | Description |
|---|---|---|
class |
JsonGenericMapper<D> |
|
class |
JsonOptionalGenericMapper<D> |
| Modifier and Type | Method | Description |
|---|---|---|
static <D> GenericMapper<D,com.google.gson.JsonElement> |
JsonGenericMapper.jsonDomainMapper() |
|
static <D> GenericMapper<Optional<D>,com.google.gson.JsonElement> |
JsonOptionalGenericMapper.jsonOptionalDomainMapper() |
| Constructor | 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) |
|
JsonCommandSerdes(GenericMapper<K,com.google.gson.JsonElement> keyMapper,
GenericMapper<C,com.google.gson.JsonElement> commandMapper) |
| Modifier and Type | Method | 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.