io.simplesource.saga.shared.app

Class StreamAppUtils

java.lang.Object

io.simplesource.saga.shared.app.StreamAppUtils

public final class StreamAppUtils
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	StreamAppUtils.ShutdownHandler

Constructor Summary

Constructors

Constructor and Description
StreamAppUtils()

Method Summary

Modifier and Type	Method and Description
static void	addShutdownHook(StreamAppUtils.ShutdownHandler handler)
static void	createMissingTopics(Properties config, List<TopicCreation> topics)
static void	runStreamApp(Properties config, org.apache.kafka.streams.Topology topology)
static void	shutdownExecutorService(ExecutorService executorService)

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamAppUtils

public StreamAppUtils()

Method Detail

createMissingTopics

public static void createMissingTopics(Properties config,
                                       List<TopicCreation> topics)

runStreamApp

public static void runStreamApp(Properties config,
                                org.apache.kafka.streams.Topology topology)

shutdownExecutorService

public static void shutdownExecutorService(ExecutorService executorService)

addShutdownHook

public static void addShutdownHook(StreamAppUtils.ShutdownHandler handler)