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