io.simplesource.kafka.dsl

Class AggregateBuilder<K,C,E,A>

java.lang.Object

io.simplesource.kafka.dsl.AggregateBuilder<K,C,E,A>

public final class AggregateBuilder<K,C,E,A>
extends Object

Method Summary

Modifier and Type	Method and Description
<SC extends C> AggregateSpec<K,C,E,A>	build()
static <K,C,E,A> AggregateBuilder<K,C,E,A>	newBuilder()
AggregateBuilder<K,C,E,A>	withAggregator(Aggregator<E,A> aggregator)
AggregateBuilder<K,C,E,A>	withCommandHandler(CommandHandler<K,C,E,A> commandHandler)
AggregateBuilder<K,C,E,A>	withCommandResponseRetention(long retentionInSeconds)
AggregateBuilder<K,C,E,A>	withDefaultTopicSpec(int partitions, int replication, int retentionDays)
AggregateBuilder<K,C,E,A>	withInitialValue(InitialValue<K,A> initialValue)
AggregateBuilder<K,C,E,A>	withInvalidSequenceStrategy(InvalidSequenceStrategy invalidSequenceStrategy)
AggregateBuilder<K,C,E,A>	withName(String name)
AggregateBuilder<K,C,E,A>	withResourceNamingStrategy(ResourceNamingStrategy resourceNamingStrategy)
AggregateBuilder<K,C,E,A>	withSerdes(AggregateSerdes<K,C,E,A> aggregateSerdes)
AggregateBuilder<K,C,E,A>	withTopicSpec(AggregateResources.TopicEntity topicEntity, TopicSpec topicSpec)

Methods inherited from class java.lang.Object

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

Method Detail

newBuilder

public static <K,C,E,A> AggregateBuilder<K,C,E,A> newBuilder()

withName

public AggregateBuilder<K,C,E,A> withName(String name)

withResourceNamingStrategy

public AggregateBuilder<K,C,E,A> withResourceNamingStrategy(ResourceNamingStrategy resourceNamingStrategy)

withSerdes

public AggregateBuilder<K,C,E,A> withSerdes(AggregateSerdes<K,C,E,A> aggregateSerdes)

withDefaultTopicSpec

public AggregateBuilder<K,C,E,A> withDefaultTopicSpec(int partitions,
                                                      int replication,
                                                      int retentionDays)

withTopicSpec

public AggregateBuilder<K,C,E,A> withTopicSpec(AggregateResources.TopicEntity topicEntity,
                                               TopicSpec topicSpec)

withCommandResponseRetention

public AggregateBuilder<K,C,E,A> withCommandResponseRetention(long retentionInSeconds)

withInitialValue

public AggregateBuilder<K,C,E,A> withInitialValue(InitialValue<K,A> initialValue)

withAggregator

public AggregateBuilder<K,C,E,A> withAggregator(Aggregator<E,A> aggregator)

withCommandHandler

public AggregateBuilder<K,C,E,A> withCommandHandler(CommandHandler<K,C,E,A> commandHandler)

withInvalidSequenceStrategy

public AggregateBuilder<K,C,E,A> withInvalidSequenceStrategy(InvalidSequenceStrategy invalidSequenceStrategy)

build

public <SC extends C> AggregateSpec<K,C,E,A> build()