Package 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	Description
CloseOptions()

Method Summary

Modifier and Type	Method	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 Details

CloseOptions

public CloseOptions()

Method Details

timeout

public KafkaStreams.CloseOptions timeout(Duration timeout)

leaveGroup

public KafkaStreams.CloseOptions leaveGroup(boolean leaveGroup)