KafkaStreams.CloseOptions (streams 8.0.3-ce API)

java.lang.Object

org.apache.kafka.streams.KafkaStreams.CloseOptions

Enclosing class:: KafkaStreams

public static class KafkaStreams.CloseOptionsextends 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
equals, 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)