Package com.bakdata.kafka

Class CloseExecutionOptions

java.lang.Object

com.bakdata.kafka.CloseExecutionOptions

public class CloseExecutionOptions
extends Object

Options to configure closing behavior of Kafka apps

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	CloseExecutionOptions.CloseExecutionOptionsBuilder

Method Summary

Modifier and Type	Method	Description
static CloseExecutionOptions.CloseExecutionOptionsBuilder	builder()
org.apache.kafka.clients.consumer.CloseOptions	createCloseOptions(org.apache.kafka.clients.consumer.ConsumerConfig config)	Create CloseOptions for Consumer
org.apache.kafka.streams.KafkaStreams.CloseOptions	createCloseOptions(org.apache.kafka.streams.StreamsConfig config)	Create KafkaStreams.CloseOptions for KafkaStreams

Methods inherited from class java.lang.Object

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

Method Details

createCloseOptions

public org.apache.kafka.streams.KafkaStreams.CloseOptions createCloseOptions(org.apache.kafka.streams.StreamsConfig config)

Create KafkaStreams.CloseOptions for KafkaStreams

Parameters:

config - streams config

Returns:

KafkaStreams.CloseOptions

See Also:

• KafkaStreams.close(CloseOptions)

createCloseOptions

public org.apache.kafka.clients.consumer.CloseOptions createCloseOptions(org.apache.kafka.clients.consumer.ConsumerConfig config)

Create CloseOptions for Consumer

Parameters:

config - consumer config

Returns:

CloseOptions

See Also:

• Consumer.close(org.apache.kafka.clients.consumer.CloseOptions)

builder

public static CloseExecutionOptions.CloseExecutionOptionsBuilder builder()