Package | Description |
---|---|
io.simplesource.kafka.dsl | |
io.simplesource.kafka.testutils |
Modifier and Type | Method and Description |
---|---|
KafkaConfig |
KafkaConfig.Builder.build() |
KafkaConfig |
KafkaConfig.Builder.build(boolean clientOnly) |
Modifier and Type | Method and Description |
---|---|
EventSourcedApp |
EventSourcedApp.withKafkaConfig(KafkaConfig kafkaConfig) |
Modifier and Type | Method and Description |
---|---|
EventSourcedClient |
EventSourcedClient.withKafkaConfig(java.util.function.Function<? super KafkaConfig.Builder,KafkaConfig> builderFn) |
EventSourcedApp |
EventSourcedApp.withKafkaConfig(java.util.function.Function<KafkaConfig.Builder,KafkaConfig> builder) |
Constructor and Description |
---|
AggregateTestDriver(AggregateSpec<K,C,E,A> aggregateSpec,
KafkaConfig kafkaConfig) |
Copyright © 2019. All rights reserved.