io.simplesource.kafka.util

Class KafkaStreamsUtils

java.lang.Object

io.simplesource.kafka.util.KafkaStreamsUtils

public final class KafkaStreamsUtils
extends Object

Constructor Summary

Constructors

Constructor and Description
KafkaStreamsUtils()

Method Summary

Modifier and Type	Method and Description
static void	addShutdownHook(org.slf4j.Logger logger, org.apache.kafka.streams.KafkaStreams streams)
static void	registerExceptionHandler(org.slf4j.Logger logger, org.apache.kafka.streams.KafkaStreams streams)
static void	waitForShutdown(org.slf4j.Logger logger, org.apache.kafka.streams.KafkaStreams streams)
static void	waitUntilStable(org.slf4j.Logger logger, org.apache.kafka.streams.KafkaStreams streams)

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaStreamsUtils

public KafkaStreamsUtils()

Method Detail

registerExceptionHandler

public static void registerExceptionHandler(org.slf4j.Logger logger,
                                            org.apache.kafka.streams.KafkaStreams streams)

addShutdownHook

public static void addShutdownHook(org.slf4j.Logger logger,
                                   org.apache.kafka.streams.KafkaStreams streams)

waitUntilStable

public static void waitUntilStable(org.slf4j.Logger logger,
                                   org.apache.kafka.streams.KafkaStreams streams)

waitForShutdown

public static void waitForShutdown(org.slf4j.Logger logger,
                                   org.apache.kafka.streams.KafkaStreams streams)