Interface DirectKafkaSource.Builder

All Superinterfaces:

Buildable, CopyableBuilder<DirectKafkaSource.Builder,DirectKafkaSource>, SdkBuilder<DirectKafkaSource.Builder,DirectKafkaSource>, SdkPojo

Enclosing class:

DirectKafkaSource

public static interface DirectKafkaSource.Builder
extends SdkPojo, CopyableBuilder<DirectKafkaSource.Builder,DirectKafkaSource>

Method Summary

Modifier and Type	Method	Description
default DirectKafkaSource.Builder	dataPreviewOptions(Consumer<StreamingDataPreviewOptions.Builder> dataPreviewOptions)	Specifies options related to data preview for viewing a sample of your data.
DirectKafkaSource.Builder	dataPreviewOptions(StreamingDataPreviewOptions dataPreviewOptions)	Specifies options related to data preview for viewing a sample of your data.
DirectKafkaSource.Builder	detectSchema(Boolean detectSchema)	Whether to automatically determine the schema from the incoming data.
DirectKafkaSource.Builder	name(String name)	The name of the data store.
default DirectKafkaSource.Builder	streamingOptions(Consumer<KafkaStreamingSourceOptions.Builder> streamingOptions)	Specifies the streaming options.
DirectKafkaSource.Builder	streamingOptions(KafkaStreamingSourceOptions streamingOptions)	Specifies the streaming options.
DirectKafkaSource.Builder	windowSize(Integer windowSize)	The amount of time to spend processing each micro batch.

Methods inherited from interface software.amazon.awssdk.utils.builder.CopyableBuilder

copy

Methods inherited from interface software.amazon.awssdk.utils.builder.SdkBuilder

applyMutation, build

Methods inherited from interface software.amazon.awssdk.core.SdkPojo

equalsBySdkFields, sdkFields

Method Details

name

DirectKafkaSource.Builder name(String name)

The name of the data store.

Parameters:

name - The name of the data store.

Returns:

Returns a reference to this object so that method calls can be chained together.

streamingOptions

DirectKafkaSource.Builder streamingOptions(KafkaStreamingSourceOptions streamingOptions)

Specifies the streaming options.

Parameters:

streamingOptions - Specifies the streaming options.

Returns:

Returns a reference to this object so that method calls can be chained together.

streamingOptions

default DirectKafkaSource.Builder streamingOptions(Consumer<KafkaStreamingSourceOptions.Builder> streamingOptions)

Specifies the streaming options.

This is a convenience method that creates an instance of the KafkaStreamingSourceOptions.Builder avoiding the need to create one manually via KafkaStreamingSourceOptions.builder().

When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to streamingOptions(KafkaStreamingSourceOptions).

Parameters:

streamingOptions - a consumer that will call methods on KafkaStreamingSourceOptions.Builder

Returns:

Returns a reference to this object so that method calls can be chained together.

See Also:

• streamingOptions(KafkaStreamingSourceOptions)

windowSize

DirectKafkaSource.Builder windowSize(Integer windowSize)

The amount of time to spend processing each micro batch.

Parameters:

windowSize - The amount of time to spend processing each micro batch.

Returns:

Returns a reference to this object so that method calls can be chained together.

detectSchema

DirectKafkaSource.Builder detectSchema(Boolean detectSchema)

Whether to automatically determine the schema from the incoming data.

Parameters:

detectSchema - Whether to automatically determine the schema from the incoming data.

Returns:

Returns a reference to this object so that method calls can be chained together.

dataPreviewOptions

DirectKafkaSource.Builder dataPreviewOptions(StreamingDataPreviewOptions dataPreviewOptions)

Specifies options related to data preview for viewing a sample of your data.

Parameters:

dataPreviewOptions - Specifies options related to data preview for viewing a sample of your data.

Returns:

Returns a reference to this object so that method calls can be chained together.

dataPreviewOptions

default DirectKafkaSource.Builder dataPreviewOptions(Consumer<StreamingDataPreviewOptions.Builder> dataPreviewOptions)

Specifies options related to data preview for viewing a sample of your data.

This is a convenience method that creates an instance of the StreamingDataPreviewOptions.Builder avoiding the need to create one manually via StreamingDataPreviewOptions.builder().

When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to dataPreviewOptions(StreamingDataPreviewOptions).

Parameters:

dataPreviewOptions - a consumer that will call methods on StreamingDataPreviewOptions.Builder

Returns:

Returns a reference to this object so that method calls can be chained together.

See Also:

• dataPreviewOptions(StreamingDataPreviewOptions)