org.apache.kafka.streams

Class KafkaStreams.CloseOptions

java.lang.Object

org.apache.kafka.streams.KafkaStreams.CloseOptions

Enclosing class:

KafkaStreams

public static class KafkaStreams.CloseOptions
extends Object

Class that handles options passed in case of KafkaStreams instance scale down

Constructor Summary

Constructors

Constructor and Description
CloseOptions()

Method Summary

Modifier and Type	Method and Description
KafkaStreams.CloseOptions	leaveGroup(boolean leaveGroup)
KafkaStreams.CloseOptions	timeout(Duration timeout)

Methods inherited from class java.lang.Object

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

Constructor Detail

CloseOptions

public CloseOptions()

Method Detail

timeout

public KafkaStreams.CloseOptions timeout(Duration timeout)

leaveGroup

public KafkaStreams.CloseOptions leaveGroup(boolean leaveGroup)