io.simplesource.kafka.dsl

Class EventSourcedClient

java.lang.Object

io.simplesource.kafka.dsl.EventSourcedClient

public final class EventSourcedClient
extends Object

Constructor Summary

Constructors

Constructor and Description
EventSourcedClient()

Method Summary

Modifier and Type	Method and Description
<K,C> EventSourcedClient	addCommands(CommandSpec<K,C> spec)
<K,C> EventSourcedClient	addCommands(java.util.function.Consumer<CommandApiBuilder<K,C>> buildSteps)
CommandAPISet	build()
EventSourcedClient	withKafkaConfig(java.util.function.Function<? super KafkaConfig.Builder,KafkaConfig> builderFn)
EventSourcedClient	withScheduler(ScheduledExecutorService scheduler)

Methods inherited from class java.lang.Object

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

Constructor Detail

EventSourcedClient

public EventSourcedClient()

Method Detail

withKafkaConfig

public EventSourcedClient withKafkaConfig(java.util.function.Function<? super KafkaConfig.Builder,KafkaConfig> builderFn)

addCommands

public <K,C> EventSourcedClient addCommands(java.util.function.Consumer<CommandApiBuilder<K,C>> buildSteps)

addCommands

public <K,C> EventSourcedClient addCommands(CommandSpec<K,C> spec)

withScheduler

public EventSourcedClient withScheduler(ScheduledExecutorService scheduler)

build

public CommandAPISet build()