A B C D F G H I J M N O P R S T U V W

A

AccountSubsystem - Interface in io.simplesource.kafka.serialization.test.wire

AccountSubsystem.Callback - Interface in io.simplesource.kafka.serialization.test.wire

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

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

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

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

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

B

balance - Variable in class io.simplesource.kafka.serialization.test.wire.CreateUserAccount

Deprecated.

balance - Variable in class io.simplesource.kafka.serialization.test.wire.UserAccount

Deprecated.

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

build() - Method in class io.simplesource.kafka.serialization.test.wire.CreateUserAccount.Builder

build() - Method in class io.simplesource.kafka.serialization.test.wire.UserAccount.Builder

C

clearBalance() - Method in class io.simplesource.kafka.serialization.test.wire.CreateUserAccount.Builder

Clears the value of the 'balance' field.

clearBalance() - Method in class io.simplesource.kafka.serialization.test.wire.UserAccount.Builder

Clears the value of the 'balance' field.

clearUsername() - Method in class io.simplesource.kafka.serialization.test.wire.CreateUserAccount.Builder

Clears the value of the 'username' field.

clearUsername() - Method in class io.simplesource.kafka.serialization.test.wire.UserAccount.Builder

Clears the value of the 'username' field.

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.json.JsonAggregateSerdes

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

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

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

createDecoder(SchemaStore) - Static method in class io.simplesource.kafka.serialization.test.wire.CreateUserAccount

Create a new BinaryMessageDecoder instance for this class that uses the specified SchemaStore.

createDecoder(SchemaStore) - Static method in class io.simplesource.kafka.serialization.test.wire.UserAccount

Create a new BinaryMessageDecoder instance for this class that uses the specified SchemaStore.

CreateUserAccount - Class in io.simplesource.kafka.serialization.test.wire

CreateUserAccount() - Constructor for class io.simplesource.kafka.serialization.test.wire.CreateUserAccount

Default constructor.

CreateUserAccount(String, BigDecimal) - Constructor for class io.simplesource.kafka.serialization.test.wire.CreateUserAccount

All-args constructor.

CreateUserAccount.Builder - Class in io.simplesource.kafka.serialization.test.wire

RecordBuilder for CreateUserAccount instances.

D

DATE_CONVERSION - Static variable in class io.simplesource.kafka.serialization.test.wire.CreateUserAccount

DATE_CONVERSION - Static variable in class io.simplesource.kafka.serialization.test.wire.UserAccount

DECIMAL_CONVERSION - Static variable in class io.simplesource.kafka.serialization.test.wire.CreateUserAccount

DECIMAL_CONVERSION - Static variable in class io.simplesource.kafka.serialization.test.wire.UserAccount

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

fromByteBuffer(ByteBuffer) - Static method in class io.simplesource.kafka.serialization.test.wire.CreateUserAccount

Deserializes a CreateUserAccount from a ByteBuffer.

fromByteBuffer(ByteBuffer) - Static method in class io.simplesource.kafka.serialization.test.wire.UserAccount

Deserializes a UserAccount from a ByteBuffer.

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

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

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

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

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

get(int) - Method in class io.simplesource.kafka.serialization.test.wire.CreateUserAccount

get(int) - Method in class io.simplesource.kafka.serialization.test.wire.UserAccount

getBalance() - Method in class io.simplesource.kafka.serialization.test.wire.CreateUserAccount.Builder

Gets the value of the 'balance' field.

getBalance() - Method in class io.simplesource.kafka.serialization.test.wire.CreateUserAccount

Gets the value of the 'balance' field.

getBalance() - Method in class io.simplesource.kafka.serialization.test.wire.UserAccount.Builder

Gets the value of the 'balance' field.

getBalance() - Method in class io.simplesource.kafka.serialization.test.wire.UserAccount

Gets the value of the 'balance' field.

getClassSchema() - Static method in class io.simplesource.kafka.serialization.test.wire.CreateUserAccount

getClassSchema() - Static method in class io.simplesource.kafka.serialization.test.wire.UserAccount

getConversion(int) - Method in class io.simplesource.kafka.serialization.test.wire.CreateUserAccount

getConversion(int) - Method in class io.simplesource.kafka.serialization.test.wire.UserAccount

getDecoder() - Static method in class io.simplesource.kafka.serialization.test.wire.CreateUserAccount

Return the BinaryMessageDecoder instance used by this class.

getDecoder() - Static method in class io.simplesource.kafka.serialization.test.wire.UserAccount

Return the BinaryMessageDecoder instance used by this class.

getSchema() - Method in class io.simplesource.kafka.serialization.test.wire.CreateUserAccount

getSchema() - Method in class io.simplesource.kafka.serialization.test.wire.UserAccount

getUsername() - Method in class io.simplesource.kafka.serialization.test.wire.CreateUserAccount.Builder

Gets the value of the 'username' field.

getUsername() - Method in class io.simplesource.kafka.serialization.test.wire.CreateUserAccount

Gets the value of the 'username' field.

getUsername() - Method in class io.simplesource.kafka.serialization.test.wire.UserAccount.Builder

Gets the value of the 'username' field.

getUsername() - Method in class io.simplesource.kafka.serialization.test.wire.UserAccount

Gets the value of the 'username' field.

H

hasBalance() - Method in class io.simplesource.kafka.serialization.test.wire.CreateUserAccount.Builder

Checks whether the 'balance' field has been set.

hasBalance() - Method in class io.simplesource.kafka.serialization.test.wire.UserAccount.Builder

Checks whether the 'balance' field has been set.

hasUsername() - Method in class io.simplesource.kafka.serialization.test.wire.CreateUserAccount.Builder

Checks whether the 'username' field has been set.

hasUsername() - Method in class io.simplesource.kafka.serialization.test.wire.UserAccount.Builder

Checks whether the 'username' field has been set.

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.test.wire - package io.simplesource.kafka.serialization.test.wire

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<A, JsonElement>, GenericMapper<E, JsonElement>, GenericMapper<C, JsonElement>, GenericMapper<K, JsonElement>) - Constructor for class io.simplesource.kafka.serialization.json.JsonAggregateSerdes

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<D>, Class<A>) - Method in class io.simplesource.kafka.serialization.avro.mappers.DomainMapperBuilder

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

N

newBuilder() - Static method in class io.simplesource.kafka.serialization.test.wire.CreateUserAccount

Creates a new CreateUserAccount RecordBuilder.

newBuilder(CreateUserAccount.Builder) - Static method in class io.simplesource.kafka.serialization.test.wire.CreateUserAccount

Creates a new CreateUserAccount RecordBuilder by copying an existing Builder.

newBuilder(CreateUserAccount) - Static method in class io.simplesource.kafka.serialization.test.wire.CreateUserAccount

Creates a new CreateUserAccount RecordBuilder by copying an existing CreateUserAccount instance.

newBuilder() - Static method in class io.simplesource.kafka.serialization.test.wire.UserAccount

Creates a new UserAccount RecordBuilder.

newBuilder(UserAccount.Builder) - Static method in class io.simplesource.kafka.serialization.test.wire.UserAccount

Creates a new UserAccount RecordBuilder by copying an existing Builder.

newBuilder(UserAccount) - Static method in class io.simplesource.kafka.serialization.test.wire.UserAccount

Creates a new UserAccount RecordBuilder by copying an existing UserAccount instance.

O

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

of(String, boolean, 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

P

PROTOCOL - Static variable in interface io.simplesource.kafka.serialization.test.wire.AccountSubsystem.Callback

PROTOCOL - Static variable in interface io.simplesource.kafka.serialization.test.wire.AccountSubsystem

put(int, Object) - Method in class io.simplesource.kafka.serialization.test.wire.CreateUserAccount

put(int, Object) - Method in class io.simplesource.kafka.serialization.test.wire.UserAccount

R

readExternal(ObjectInput) - Method in class io.simplesource.kafka.serialization.test.wire.CreateUserAccount

readExternal(ObjectInput) - Method in class io.simplesource.kafka.serialization.test.wire.UserAccount

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

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

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

SCHEMA$ - Static variable in class io.simplesource.kafka.serialization.test.wire.CreateUserAccount

SCHEMA$ - Static variable in class io.simplesource.kafka.serialization.test.wire.UserAccount

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

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

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

setBalance(BigDecimal) - Method in class io.simplesource.kafka.serialization.test.wire.CreateUserAccount.Builder

Sets the value of the 'balance' field.

setBalance(BigDecimal) - Method in class io.simplesource.kafka.serialization.test.wire.CreateUserAccount

Sets the value of the 'balance' field.

setBalance(BigDecimal) - Method in class io.simplesource.kafka.serialization.test.wire.UserAccount.Builder

Sets the value of the 'balance' field.

setBalance(BigDecimal) - Method in class io.simplesource.kafka.serialization.test.wire.UserAccount

Sets the value of the 'balance' field.

setUsername(String) - Method in class io.simplesource.kafka.serialization.test.wire.CreateUserAccount.Builder

Sets the value of the 'username' field.

setUsername(String) - Method in class io.simplesource.kafka.serialization.test.wire.CreateUserAccount

Sets the value of the 'username' field.

setUsername(String) - Method in class io.simplesource.kafka.serialization.test.wire.UserAccount.Builder

Sets the value of the 'username' field.

setUsername(String) - Method in class io.simplesource.kafka.serialization.test.wire.UserAccount

Sets the value of the 'username' field.

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

T

TIME_CONVERSION - Static variable in class io.simplesource.kafka.serialization.test.wire.CreateUserAccount

TIME_CONVERSION - Static variable in class io.simplesource.kafka.serialization.test.wire.UserAccount

TIMESTAMP_CONVERSION - Static variable in class io.simplesource.kafka.serialization.test.wire.CreateUserAccount

TIMESTAMP_CONVERSION - Static variable in class io.simplesource.kafka.serialization.test.wire.UserAccount

toByteBuffer() - Method in class io.simplesource.kafka.serialization.test.wire.CreateUserAccount

Serializes this CreateUserAccount to a ByteBuffer.

toByteBuffer() - Method in class io.simplesource.kafka.serialization.test.wire.UserAccount

Serializes this UserAccount to a ByteBuffer.

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

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

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 interface io.simplesource.kafka.serialization.util.GenericMapper

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

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

U

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

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

UserAccount - Class in io.simplesource.kafka.serialization.test.wire

UserAccount() - Constructor for class io.simplesource.kafka.serialization.test.wire.UserAccount

Default constructor.

UserAccount(String, BigDecimal) - Constructor for class io.simplesource.kafka.serialization.test.wire.UserAccount

All-args constructor.

UserAccount.Builder - Class in io.simplesource.kafka.serialization.test.wire

RecordBuilder for UserAccount instances.

username - Variable in class io.simplesource.kafka.serialization.test.wire.CreateUserAccount

Deprecated.

username - Variable in class io.simplesource.kafka.serialization.test.wire.UserAccount

Deprecated.

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

writeExternal(ObjectOutput) - Method in class io.simplesource.kafka.serialization.test.wire.CreateUserAccount

writeExternal(ObjectOutput) - Method in class io.simplesource.kafka.serialization.test.wire.UserAccount

A B C D F G H I J M N O P R S T U V W