Package com.pulumi.aws.pipes.inputs

Class PipeSourceParametersSelfManagedKafkaParametersArgs.Builder

java.lang.Object

com.pulumi.aws.pipes.inputs.PipeSourceParametersSelfManagedKafkaParametersArgs.Builder

Enclosing class:

PipeSourceParametersSelfManagedKafkaParametersArgs

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

Constructor Summary

Constructors

Constructor	Description
Builder()
Builder(PipeSourceParametersSelfManagedKafkaParametersArgs defaults)

Method Summary

Modifier and Type	Method	Description
PipeSourceParametersSelfManagedKafkaParametersArgs.Builder	additionalBootstrapServers(com.pulumi.core.Output<java.util.List<java.lang.String>> additionalBootstrapServers)
PipeSourceParametersSelfManagedKafkaParametersArgs.Builder	additionalBootstrapServers(java.lang.String... additionalBootstrapServers)
PipeSourceParametersSelfManagedKafkaParametersArgs.Builder	additionalBootstrapServers(java.util.List<java.lang.String> additionalBootstrapServers)
PipeSourceParametersSelfManagedKafkaParametersArgs.Builder	batchSize(com.pulumi.core.Output<java.lang.Integer> batchSize)
PipeSourceParametersSelfManagedKafkaParametersArgs.Builder	batchSize(java.lang.Integer batchSize)
PipeSourceParametersSelfManagedKafkaParametersArgs	build()
PipeSourceParametersSelfManagedKafkaParametersArgs.Builder	consumerGroupId(com.pulumi.core.Output<java.lang.String> consumerGroupId)
PipeSourceParametersSelfManagedKafkaParametersArgs.Builder	consumerGroupId(java.lang.String consumerGroupId)
PipeSourceParametersSelfManagedKafkaParametersArgs.Builder	credentials(PipeSourceParametersSelfManagedKafkaParametersCredentialsArgs credentials)
PipeSourceParametersSelfManagedKafkaParametersArgs.Builder	credentials(com.pulumi.core.Output<PipeSourceParametersSelfManagedKafkaParametersCredentialsArgs> credentials)
PipeSourceParametersSelfManagedKafkaParametersArgs.Builder	maximumBatchingWindowInSeconds(com.pulumi.core.Output<java.lang.Integer> maximumBatchingWindowInSeconds)
PipeSourceParametersSelfManagedKafkaParametersArgs.Builder	maximumBatchingWindowInSeconds(java.lang.Integer maximumBatchingWindowInSeconds)
PipeSourceParametersSelfManagedKafkaParametersArgs.Builder	serverRootCaCertificate(com.pulumi.core.Output<java.lang.String> serverRootCaCertificate)
PipeSourceParametersSelfManagedKafkaParametersArgs.Builder	serverRootCaCertificate(java.lang.String serverRootCaCertificate)
PipeSourceParametersSelfManagedKafkaParametersArgs.Builder	startingPosition(com.pulumi.core.Output<java.lang.String> startingPosition)
PipeSourceParametersSelfManagedKafkaParametersArgs.Builder	startingPosition(java.lang.String startingPosition)
PipeSourceParametersSelfManagedKafkaParametersArgs.Builder	topicName(com.pulumi.core.Output<java.lang.String> topicName)
PipeSourceParametersSelfManagedKafkaParametersArgs.Builder	topicName(java.lang.String topicName)
PipeSourceParametersSelfManagedKafkaParametersArgs.Builder	vpc(PipeSourceParametersSelfManagedKafkaParametersVpcArgs vpc)
PipeSourceParametersSelfManagedKafkaParametersArgs.Builder	vpc(com.pulumi.core.Output<PipeSourceParametersSelfManagedKafkaParametersVpcArgs> vpc)

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(PipeSourceParametersSelfManagedKafkaParametersArgs defaults)

Method Detail

additionalBootstrapServers

public PipeSourceParametersSelfManagedKafkaParametersArgs.Builder additionalBootstrapServers(@Nullable
                                                                                             com.pulumi.core.Output<java.util.List<java.lang.String>> additionalBootstrapServers)

Parameters:

additionalBootstrapServers - Array of server URLs. Maximum number of 2 items, each of maximum length 300.

Returns:

builder

additionalBootstrapServers

public PipeSourceParametersSelfManagedKafkaParametersArgs.Builder additionalBootstrapServers(java.util.List<java.lang.String> additionalBootstrapServers)

Parameters:

additionalBootstrapServers - Array of server URLs. Maximum number of 2 items, each of maximum length 300.

Returns:

builder

additionalBootstrapServers

public PipeSourceParametersSelfManagedKafkaParametersArgs.Builder additionalBootstrapServers(java.lang.String... additionalBootstrapServers)

Parameters:

additionalBootstrapServers - Array of server URLs. Maximum number of 2 items, each of maximum length 300.

Returns:

builder

batchSize

public PipeSourceParametersSelfManagedKafkaParametersArgs.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 PipeSourceParametersSelfManagedKafkaParametersArgs.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 PipeSourceParametersSelfManagedKafkaParametersArgs.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 PipeSourceParametersSelfManagedKafkaParametersArgs.Builder consumerGroupId(java.lang.String consumerGroupId)

Parameters:

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

Returns:

builder

credentials

public PipeSourceParametersSelfManagedKafkaParametersArgs.Builder credentials(@Nullable
                                                                              com.pulumi.core.Output<PipeSourceParametersSelfManagedKafkaParametersCredentialsArgs> credentials)

Parameters:

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

Returns:

builder

credentials

public PipeSourceParametersSelfManagedKafkaParametersArgs.Builder credentials(PipeSourceParametersSelfManagedKafkaParametersCredentialsArgs credentials)

Parameters:

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

Returns:

builder

maximumBatchingWindowInSeconds

public PipeSourceParametersSelfManagedKafkaParametersArgs.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 PipeSourceParametersSelfManagedKafkaParametersArgs.Builder maximumBatchingWindowInSeconds(java.lang.Integer maximumBatchingWindowInSeconds)

Parameters:

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

Returns:

builder

serverRootCaCertificate

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

Parameters:

serverRootCaCertificate - ARN of the Secrets Manager secret used for certification.

Returns:

builder

serverRootCaCertificate

public PipeSourceParametersSelfManagedKafkaParametersArgs.Builder serverRootCaCertificate(java.lang.String serverRootCaCertificate)

Parameters:

serverRootCaCertificate - ARN of the Secrets Manager secret used for certification.

Returns:

builder

startingPosition

public PipeSourceParametersSelfManagedKafkaParametersArgs.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 PipeSourceParametersSelfManagedKafkaParametersArgs.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 PipeSourceParametersSelfManagedKafkaParametersArgs.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 PipeSourceParametersSelfManagedKafkaParametersArgs.Builder topicName(java.lang.String topicName)

Parameters:

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

Returns:

builder

vpc

public PipeSourceParametersSelfManagedKafkaParametersArgs.Builder vpc(@Nullable
                                                                      com.pulumi.core.Output<PipeSourceParametersSelfManagedKafkaParametersVpcArgs> vpc)

Parameters:

vpc - VPC subnets and security groups for the stream, and whether a public IP address is to be used. See `vpc` Block for details.

Returns:

builder

vpc

public PipeSourceParametersSelfManagedKafkaParametersArgs.Builder vpc(PipeSourceParametersSelfManagedKafkaParametersVpcArgs vpc)

Parameters:

vpc - VPC subnets and security groups for the stream, and whether a public IP address is to be used. See `vpc` Block for details.

Returns:

builder

build

public PipeSourceParametersSelfManagedKafkaParametersArgs build()