Class CfnPipePropsMixin.PipeSourceSelfManagedKafkaParametersProperty.Builder
java.lang.Object
software.amazon.awscdk.cfnpropertymixins.services.pipes.CfnPipePropsMixin.PipeSourceSelfManagedKafkaParametersProperty.Builder
- All Implemented Interfaces:
software.amazon.jsii.Builder<CfnPipePropsMixin.PipeSourceSelfManagedKafkaParametersProperty>
- Enclosing interface:
CfnPipePropsMixin.PipeSourceSelfManagedKafkaParametersProperty
@Stability(Stable)
public static final class CfnPipePropsMixin.PipeSourceSelfManagedKafkaParametersProperty.Builder
extends Object
implements software.amazon.jsii.Builder<CfnPipePropsMixin.PipeSourceSelfManagedKafkaParametersProperty>
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionadditionalBootstrapServers(List<String> additionalBootstrapServers) build()Builds the configured instance.consumerGroupId(String consumerGroupId) credentials(IResolvable credentials) maximumBatchingWindowInSeconds(Number maximumBatchingWindowInSeconds) serverRootCaCertificate(String serverRootCaCertificate) startingPosition(String startingPosition) Sets the value ofCfnPipePropsMixin.PipeSourceSelfManagedKafkaParametersProperty.getVpc()vpc(IResolvable vpc) Sets the value ofCfnPipePropsMixin.PipeSourceSelfManagedKafkaParametersProperty.getVpc()
-
Constructor Details
-
Builder
public Builder()
-
-
Method Details
-
additionalBootstrapServers
@Stability(Stable) public CfnPipePropsMixin.PipeSourceSelfManagedKafkaParametersProperty.Builder additionalBootstrapServers(List<String> additionalBootstrapServers) Sets the value ofCfnPipePropsMixin.PipeSourceSelfManagedKafkaParametersProperty.getAdditionalBootstrapServers()- Parameters:
additionalBootstrapServers- An array of server URLs.- Returns:
this
-
batchSize
@Stability(Stable) public CfnPipePropsMixin.PipeSourceSelfManagedKafkaParametersProperty.Builder batchSize(Number batchSize) - Parameters:
batchSize- The maximum number of records to include in each batch.- Returns:
this
-
consumerGroupId
@Stability(Stable) public CfnPipePropsMixin.PipeSourceSelfManagedKafkaParametersProperty.Builder consumerGroupId(String consumerGroupId) Sets the value ofCfnPipePropsMixin.PipeSourceSelfManagedKafkaParametersProperty.getConsumerGroupId()- Parameters:
consumerGroupId- The name of the destination queue to consume.- Returns:
this
-
credentials
@Stability(Stable) public CfnPipePropsMixin.PipeSourceSelfManagedKafkaParametersProperty.Builder credentials(IResolvable credentials) - Parameters:
credentials- The credentials needed to access the resource.- Returns:
this
-
credentials
@Stability(Stable) public CfnPipePropsMixin.PipeSourceSelfManagedKafkaParametersProperty.Builder credentials(CfnPipePropsMixin.SelfManagedKafkaAccessConfigurationCredentialsProperty credentials) - Parameters:
credentials- The credentials needed to access the resource.- Returns:
this
-
maximumBatchingWindowInSeconds
@Stability(Stable) public CfnPipePropsMixin.PipeSourceSelfManagedKafkaParametersProperty.Builder maximumBatchingWindowInSeconds(Number maximumBatchingWindowInSeconds) Sets the value ofCfnPipePropsMixin.PipeSourceSelfManagedKafkaParametersProperty.getMaximumBatchingWindowInSeconds()- Parameters:
maximumBatchingWindowInSeconds- The maximum length of a time to wait for events.- Returns:
this
-
serverRootCaCertificate
@Stability(Stable) public CfnPipePropsMixin.PipeSourceSelfManagedKafkaParametersProperty.Builder serverRootCaCertificate(String serverRootCaCertificate) Sets the value ofCfnPipePropsMixin.PipeSourceSelfManagedKafkaParametersProperty.getServerRootCaCertificate()- Parameters:
serverRootCaCertificate- The ARN of the Secrets Manager secret used for certification.- Returns:
this
-
startingPosition
@Stability(Stable) public CfnPipePropsMixin.PipeSourceSelfManagedKafkaParametersProperty.Builder startingPosition(String startingPosition) Sets the value ofCfnPipePropsMixin.PipeSourceSelfManagedKafkaParametersProperty.getStartingPosition()- Parameters:
startingPosition- The position in a stream from which to start reading.- Returns:
this
-
topicName
@Stability(Stable) public CfnPipePropsMixin.PipeSourceSelfManagedKafkaParametersProperty.Builder topicName(String topicName) - Parameters:
topicName- The name of the topic that the pipe will read from.- Returns:
this
-
vpc
@Stability(Stable) public CfnPipePropsMixin.PipeSourceSelfManagedKafkaParametersProperty.Builder vpc(IResolvable vpc) Sets the value ofCfnPipePropsMixin.PipeSourceSelfManagedKafkaParametersProperty.getVpc()- Parameters:
vpc- This structure specifies the VPC subnets and security groups for the stream, and whether a public IP address is to be used.- Returns:
this
-
vpc
@Stability(Stable) public CfnPipePropsMixin.PipeSourceSelfManagedKafkaParametersProperty.Builder vpc(CfnPipePropsMixin.SelfManagedKafkaAccessConfigurationVpcProperty vpc) Sets the value ofCfnPipePropsMixin.PipeSourceSelfManagedKafkaParametersProperty.getVpc()- Parameters:
vpc- This structure specifies the VPC subnets and security groups for the stream, and whether a public IP address is to be used.- Returns:
this
-
build
Builds the configured instance.- Specified by:
buildin interfacesoftware.amazon.jsii.Builder<CfnPipePropsMixin.PipeSourceSelfManagedKafkaParametersProperty>- Returns:
- a new instance of
CfnPipePropsMixin.PipeSourceSelfManagedKafkaParametersProperty - Throws:
NullPointerException- if any required attribute was not provided
-