A B C D F G I J M O R S T V W

A

aggregateKey() - Method in class io.simplesource.kafka.serialization.avro.AvroAggregateSerdes

aggregateKey() - Method in class io.simplesource.kafka.serialization.avro.AvroCommandSerdes

aggregateKey() - Method in class io.simplesource.kafka.serialization.json.JsonAggregateSerdes

aggregateKey() - Method in class io.simplesource.kafka.serialization.json.JsonCommandSerdes

aggregateUpdate() - Method in class io.simplesource.kafka.serialization.avro.AvroAggregateSerdes

aggregateUpdate() - Method in class io.simplesource.kafka.serialization.json.JsonAggregateSerdes

AvroAggregateSerdes<K,C,E,A> - Class in io.simplesource.kafka.serialization.avro

AvroAggregateSerdes(GenericMapper<K, GenericRecord>, GenericMapper<C, GenericRecord>, GenericMapper<E, GenericRecord>, GenericMapper<A, GenericRecord>, String, boolean, Schema) - Constructor for class io.simplesource.kafka.serialization.avro.AvroAggregateSerdes

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

AvroCommandSerdes(GenericMapper<K, GenericRecord>, GenericMapper<C, GenericRecord>, String, boolean) - Constructor for class io.simplesource.kafka.serialization.avro.AvroCommandSerdes

AvroGenericUtils - Class in io.simplesource.kafka.serialization.avro

AvroGenericUtils() - Constructor for class io.simplesource.kafka.serialization.avro.AvroGenericUtils

AvroGenericUtils.SchemaNameStrategy - Enum in io.simplesource.kafka.serialization.avro

AvroGenericUtils.ValueWithSequenceAvroHelper - Class in io.simplesource.kafka.serialization.avro

AvroSerdes - Class in io.simplesource.kafka.serialization.avro

AvroSerdes() - Constructor for class io.simplesource.kafka.serialization.avro.AvroSerdes

AvroSpecificGenericMapper<D extends org.apache.avro.generic.GenericRecord> - Class in io.simplesource.kafka.serialization.avro

B

build() - Method in class io.simplesource.kafka.serialization.avro.mappers.DomainMapperBuilder

build(GenericMapper<A, GenericRecord>) - Method in class io.simplesource.kafka.serialization.avro.mappers.DomainMapperBuilder

C

close() - Method in class io.simplesource.kafka.serialization.util.GenericSerde

commandRequest() - Method in class io.simplesource.kafka.serialization.avro.AvroAggregateSerdes

commandRequest() - Method in class io.simplesource.kafka.serialization.avro.AvroCommandSerdes

commandRequest() - Method in class io.simplesource.kafka.serialization.json.JsonAggregateSerdes

commandRequest() - Method in class io.simplesource.kafka.serialization.json.JsonCommandSerdes

commandResponse() - Method in class io.simplesource.kafka.serialization.avro.AvroAggregateSerdes

commandResponse() - Method in class io.simplesource.kafka.serialization.avro.AvroCommandSerdes

commandResponse() - Method in class io.simplesource.kafka.serialization.json.JsonAggregateSerdes

commandResponse() - Method in class io.simplesource.kafka.serialization.json.JsonCommandSerdes

commandResponseKey() - Method in class io.simplesource.kafka.serialization.avro.AvroAggregateSerdes

commandResponseKey() - Method in class io.simplesource.kafka.serialization.avro.AvroCommandSerdes

commandResponseKey() - Method in class io.simplesource.kafka.serialization.json.JsonAggregateSerdes

commandResponseKey() - Method in class io.simplesource.kafka.serialization.json.JsonCommandSerdes

configure(Map<String, ?>, boolean) - Method in class io.simplesource.kafka.serialization.util.GenericSerde

D

deserializer() - Method in class io.simplesource.kafka.serialization.util.GenericSerde

DomainMapperBuilder - Class in io.simplesource.kafka.serialization.avro.mappers

DomainMapperBuilder() - Constructor for class io.simplesource.kafka.serialization.avro.mappers.DomainMapperBuilder

DomainMapperBuilder(DomainMapperRegistry) - Constructor for class io.simplesource.kafka.serialization.avro.mappers.DomainMapperBuilder

DomainMapperRegistry - Class in io.simplesource.kafka.serialization.avro.mappers

DomainMapperRegistry() - Constructor for class io.simplesource.kafka.serialization.avro.mappers.DomainMapperRegistry

DomainSerializedClassMapper<D,A extends org.apache.avro.generic.GenericRecord> - Interface in io.simplesource.kafka.serialization.avro.mappers

Mapper for domain and serialized class pairs.

DomainSerializedClassMapperFromSerializedStep<D,A extends org.apache.avro.generic.GenericRecord> - Interface in io.simplesource.kafka.serialization.avro.mappers.steps

DomainSerializedClassMapperRegisterStep - Interface in io.simplesource.kafka.serialization.avro.mappers.steps

DomainSerializedClassMapperToSerializedStep<D,A extends org.apache.avro.generic.GenericRecord> - Interface in io.simplesource.kafka.serialization.avro.mappers.steps

F

fromGeneric(JsonElement) - Method in class io.simplesource.kafka.serialization.json.JsonGenericMapper

fromGeneric(JsonElement) - Method in class io.simplesource.kafka.serialization.json.JsonOptionalGenericMapper

fromGeneric(GenericRecord) - Method in class io.simplesource.kafka.serialization.avro.AvroSpecificGenericMapper

fromGeneric(S) - Method in class io.simplesource.kafka.serialization.avro.mappers.RegistryBasedDomainMapper

fromGeneric(S) - Method in interface io.simplesource.kafka.serialization.util.GenericMapper

fromGenericRecord(GenericRecord) - Static method in class io.simplesource.kafka.serialization.avro.AvroGenericUtils.ValueWithSequenceAvroHelper

fromSerialized(Function<A, D>) - Method in interface io.simplesource.kafka.serialization.avro.mappers.steps.DomainSerializedClassMapperFromSerializedStep

G

genericAvroSerde(String, boolean, boolean) - Static method in class io.simplesource.kafka.serialization.avro.AvroGenericUtils

genericAvroSerde(String, boolean, boolean, AvroGenericUtils.SchemaNameStrategy) - Static method in class io.simplesource.kafka.serialization.avro.AvroGenericUtils

GenericMapper<V,S> - Interface in io.simplesource.kafka.serialization.util

Provides a mapping from your domain classes for aggregates, events, commands and keys to a generic serialization class used to read and write from Kafka.

GenericSerde<A,S> - Class in io.simplesource.kafka.serialization.util

I

io.simplesource.kafka.serialization.avro - package io.simplesource.kafka.serialization.avro

io.simplesource.kafka.serialization.avro.mappers - package io.simplesource.kafka.serialization.avro.mappers

io.simplesource.kafka.serialization.avro.mappers.steps - package io.simplesource.kafka.serialization.avro.mappers.steps

io.simplesource.kafka.serialization.json - package io.simplesource.kafka.serialization.json

io.simplesource.kafka.serialization.util - package io.simplesource.kafka.serialization.util

J

JsonAggregateSerdes<K,C,E,A> - Class in io.simplesource.kafka.serialization.json

JsonAggregateSerdes() - Constructor for class io.simplesource.kafka.serialization.json.JsonAggregateSerdes

JsonAggregateSerdes(GenericMapper<K, JsonElement>, GenericMapper<C, JsonElement>, GenericMapper<E, JsonElement>, GenericMapper<A, JsonElement>) - Constructor for class io.simplesource.kafka.serialization.json.JsonAggregateSerdes

JsonCommandSerdes<K,C> - Class in io.simplesource.kafka.serialization.json

JsonCommandSerdes() - Constructor for class io.simplesource.kafka.serialization.json.JsonCommandSerdes

JsonCommandSerdes(GenericMapper<K, JsonElement>, GenericMapper<C, JsonElement>) - Constructor for class io.simplesource.kafka.serialization.json.JsonCommandSerdes

jsonDomainMapper() - Static method in class io.simplesource.kafka.serialization.json.JsonGenericMapper

JsonGenericMapper<D> - Class in io.simplesource.kafka.serialization.json

jsonOptionalDomainMapper() - Static method in class io.simplesource.kafka.serialization.json.JsonOptionalGenericMapper

JsonOptionalGenericMapper<D> - Class in io.simplesource.kafka.serialization.json

M

mapperFor(Class) - Method in class io.simplesource.kafka.serialization.avro.mappers.DomainMapperRegistry

mapperFor(Class<?>, Class<?>) - Method in interface io.simplesource.kafka.serialization.avro.mappers.DomainSerializedClassMapper

mapperFor(Class<D>, Class<A>) - Method in class io.simplesource.kafka.serialization.avro.mappers.DomainMapperBuilder

O

of(GenericMapper<K, GenericRecord>, GenericMapper<C, GenericRecord>, String, boolean) - Static method in class io.simplesource.kafka.serialization.avro.AvroCommandSerdes

of(String) - Static method in class io.simplesource.kafka.serialization.avro.AvroCommandSerdes

of(String, boolean) - Static method in class io.simplesource.kafka.serialization.avro.AvroCommandSerdes

of(String, boolean, Schema) - Static method in class io.simplesource.kafka.serialization.avro.AvroAggregateSerdes

of(String, Schema) - Static method in class io.simplesource.kafka.serialization.avro.AvroAggregateSerdes

of(Serde<S>, GenericMapper<A, S>) - Static method in class io.simplesource.kafka.serialization.util.GenericSerde

of(Serde<S>, Function<A, S>, Function<S, A>) - Static method in class io.simplesource.kafka.serialization.util.GenericSerde

optionalMapperFor(Class<D>, Class<A>) - Method in class io.simplesource.kafka.serialization.avro.mappers.DomainMapperBuilder

R

register() - Method in interface io.simplesource.kafka.serialization.avro.mappers.steps.DomainSerializedClassMapperRegisterStep

register(Class<?>, Class<?>, Function<D, A>, Function<A, D>) - Method in class io.simplesource.kafka.serialization.avro.mappers.DomainMapperRegistry

RegistryBasedDomainMapper<V,S extends org.apache.avro.generic.GenericRecord> - Class in io.simplesource.kafka.serialization.avro.mappers

Domain mapper implementation using registry for all supported domain-serialized class combinations

S

serializer() - Method in class io.simplesource.kafka.serialization.util.GenericSerde

specificDomainMapper() - Static method in class io.simplesource.kafka.serialization.avro.AvroSpecificGenericMapper

T

toGeneric(D) - Method in class io.simplesource.kafka.serialization.avro.AvroSpecificGenericMapper

toGeneric(D) - Method in class io.simplesource.kafka.serialization.json.JsonGenericMapper

toGeneric(Optional<D>) - Method in class io.simplesource.kafka.serialization.json.JsonOptionalGenericMapper

toGeneric(V) - Method in class io.simplesource.kafka.serialization.avro.mappers.RegistryBasedDomainMapper

toGeneric(V) - Method in interface io.simplesource.kafka.serialization.util.GenericMapper

toGenericRecord(ValueWithSequence<GenericRecord>) - Static method in class io.simplesource.kafka.serialization.avro.AvroGenericUtils.ValueWithSequenceAvroHelper

TOPIC_NAME - io.simplesource.kafka.serialization.avro.AvroGenericUtils.SchemaNameStrategy

TOPIC_RECORD_NAME - io.simplesource.kafka.serialization.avro.AvroGenericUtils.SchemaNameStrategy

toSerialized(Function<D, A>) - Method in interface io.simplesource.kafka.serialization.avro.mappers.steps.DomainSerializedClassMapperToSerializedStep

V

valueOf(String) - Static method in enum io.simplesource.kafka.serialization.avro.AvroGenericUtils.SchemaNameStrategy

Returns the enum constant of this type with the specified name.

values() - Static method in enum io.simplesource.kafka.serialization.avro.AvroGenericUtils.SchemaNameStrategy

Returns an array containing the constants of this enum type, in the order they are declared.

valueWithSequence() - Method in class io.simplesource.kafka.serialization.avro.AvroAggregateSerdes

valueWithSequence() - Method in class io.simplesource.kafka.serialization.json.JsonAggregateSerdes

ValueWithSequenceAvroHelper() - Constructor for class io.simplesource.kafka.serialization.avro.AvroGenericUtils.ValueWithSequenceAvroHelper

W

withExceptionSupplierForNotRegisteredMapper(Supplier<RuntimeException>) - Method in class io.simplesource.kafka.serialization.avro.mappers.DomainMapperBuilder

A B C D F G I J M O R S T V W