Package com.pulumi.aws.pipes.inputs

Class PipeSourceParametersManagedStreamingKafkaParametersArgs.Builder

java.lang.Object

com.pulumi.aws.pipes.inputs.PipeSourceParametersManagedStreamingKafkaParametersArgs.Builder

Enclosing class:

PipeSourceParametersManagedStreamingKafkaParametersArgs

public static final class PipeSourceParametersManagedStreamingKafkaParametersArgs.Builder
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
Builder()
Builder(PipeSourceParametersManagedStreamingKafkaParametersArgs defaults)

Method Summary

Modifier and Type	Method	Description
PipeSourceParametersManagedStreamingKafkaParametersArgs.Builder	batchSize(com.pulumi.core.Output<java.lang.Integer> batchSize)
PipeSourceParametersManagedStreamingKafkaParametersArgs.Builder	batchSize(java.lang.Integer batchSize)
PipeSourceParametersManagedStreamingKafkaParametersArgs	build()
PipeSourceParametersManagedStreamingKafkaParametersArgs.Builder	consumerGroupId(com.pulumi.core.Output<java.lang.String> consumerGroupId)
PipeSourceParametersManagedStreamingKafkaParametersArgs.Builder	consumerGroupId(java.lang.String consumerGroupId)
PipeSourceParametersManagedStreamingKafkaParametersArgs.Builder	credentials(PipeSourceParametersManagedStreamingKafkaParametersCredentialsArgs credentials)
PipeSourceParametersManagedStreamingKafkaParametersArgs.Builder	credentials(com.pulumi.core.Output<PipeSourceParametersManagedStreamingKafkaParametersCredentialsArgs> credentials)
PipeSourceParametersManagedStreamingKafkaParametersArgs.Builder	maximumBatchingWindowInSeconds(com.pulumi.core.Output<java.lang.Integer> maximumBatchingWindowInSeconds)
PipeSourceParametersManagedStreamingKafkaParametersArgs.Builder	maximumBatchingWindowInSeconds(java.lang.Integer maximumBatchingWindowInSeconds)
PipeSourceParametersManagedStreamingKafkaParametersArgs.Builder	startingPosition(com.pulumi.core.Output<java.lang.String> startingPosition)
PipeSourceParametersManagedStreamingKafkaParametersArgs.Builder	startingPosition(java.lang.String startingPosition)
PipeSourceParametersManagedStreamingKafkaParametersArgs.Builder	topicName(com.pulumi.core.Output<java.lang.String> topicName)
PipeSourceParametersManagedStreamingKafkaParametersArgs.Builder	topicName(java.lang.String topicName)

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder()

Builder

public Builder(PipeSourceParametersManagedStreamingKafkaParametersArgs defaults)

Method Detail

batchSize

public PipeSourceParametersManagedStreamingKafkaParametersArgs.Builder batchSize(@Nullable
                                                                                 com.pulumi.core.Output<java.lang.Integer> batchSize)

Parameters:

batchSize - Maximum number of records to include in each batch. Maximum value of 10000.

Returns:

builder

batchSize

public PipeSourceParametersManagedStreamingKafkaParametersArgs.Builder batchSize(java.lang.Integer batchSize)

Parameters:

batchSize - Maximum number of records to include in each batch. Maximum value of 10000.

Returns:

builder

consumerGroupId

public PipeSourceParametersManagedStreamingKafkaParametersArgs.Builder consumerGroupId(@Nullable
                                                                                       com.pulumi.core.Output<java.lang.String> consumerGroupId)

Parameters:

consumerGroupId - Name of the destination queue to consume. Maximum value of 200.

Returns:

builder

consumerGroupId

public PipeSourceParametersManagedStreamingKafkaParametersArgs.Builder consumerGroupId(java.lang.String consumerGroupId)

Parameters:

consumerGroupId - Name of the destination queue to consume. Maximum value of 200.

Returns:

builder

credentials

public PipeSourceParametersManagedStreamingKafkaParametersArgs.Builder credentials(@Nullable
                                                                                   com.pulumi.core.Output<PipeSourceParametersManagedStreamingKafkaParametersCredentialsArgs> credentials)

Parameters:

credentials - Credentials needed to access the resource. See `source_parameters.managed_streaming_kafka_parameters.credentials` Block for details.

Returns:

builder

credentials

public PipeSourceParametersManagedStreamingKafkaParametersArgs.Builder credentials(PipeSourceParametersManagedStreamingKafkaParametersCredentialsArgs credentials)

Parameters:

credentials - Credentials needed to access the resource. See `source_parameters.managed_streaming_kafka_parameters.credentials` Block for details.

Returns:

builder

maximumBatchingWindowInSeconds

public PipeSourceParametersManagedStreamingKafkaParametersArgs.Builder maximumBatchingWindowInSeconds(@Nullable
                                                                                                      com.pulumi.core.Output<java.lang.Integer> maximumBatchingWindowInSeconds)

Parameters:

maximumBatchingWindowInSeconds - Maximum length of a time to wait for events. Maximum value of 300.

Returns:

builder

maximumBatchingWindowInSeconds

public PipeSourceParametersManagedStreamingKafkaParametersArgs.Builder maximumBatchingWindowInSeconds(java.lang.Integer maximumBatchingWindowInSeconds)

Parameters:

maximumBatchingWindowInSeconds - Maximum length of a time to wait for events. Maximum value of 300.

Returns:

builder

startingPosition

public PipeSourceParametersManagedStreamingKafkaParametersArgs.Builder startingPosition(@Nullable
                                                                                        com.pulumi.core.Output<java.lang.String> startingPosition)

Parameters:

startingPosition - Position in a stream from which to start reading. Valid values: TRIM_HORIZON, LATEST.

Returns:

builder

startingPosition

public PipeSourceParametersManagedStreamingKafkaParametersArgs.Builder startingPosition(java.lang.String startingPosition)

Parameters:

startingPosition - Position in a stream from which to start reading. Valid values: TRIM_HORIZON, LATEST.

Returns:

builder

topicName

public PipeSourceParametersManagedStreamingKafkaParametersArgs.Builder topicName(com.pulumi.core.Output<java.lang.String> topicName)

Parameters:

topicName - Name of the topic that the pipe will read from. Maximum length of 249.

Returns:

builder

topicName

public PipeSourceParametersManagedStreamingKafkaParametersArgs.Builder topicName(java.lang.String topicName)

Parameters:

topicName - Name of the topic that the pipe will read from. Maximum length of 249.

Returns:

builder

build

public PipeSourceParametersManagedStreamingKafkaParametersArgs build()