io.simplesource.saga.shared.app

Class StreamBuildSpec

java.lang.Object

io.simplesource.saga.shared.app.StreamBuildSpec

public class StreamBuildSpec
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
List<TopicCreation>	topics
java.util.function.Function<org.apache.kafka.streams.StreamsBuilder,Optional<StreamAppUtils.ShutdownHandler>>	topologyBuildStep

Constructor Summary

Constructors

Constructor and Description
StreamBuildSpec()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

topics

public final List<TopicCreation> topics

topologyBuildStep

public final java.util.function.Function<org.apache.kafka.streams.StreamsBuilder,Optional<StreamAppUtils.ShutdownHandler>> topologyBuildStep

Constructor Detail

StreamBuildSpec

public StreamBuildSpec()