Interface UpdatePipeSourceSelfManagedKafkaParameters.Builder
- All Superinterfaces:
Buildable
,CopyableBuilder<UpdatePipeSourceSelfManagedKafkaParameters.Builder,
,UpdatePipeSourceSelfManagedKafkaParameters> SdkBuilder<UpdatePipeSourceSelfManagedKafkaParameters.Builder,
,UpdatePipeSourceSelfManagedKafkaParameters> SdkPojo
- Enclosing class:
UpdatePipeSourceSelfManagedKafkaParameters
-
Method Summary
Modifier and TypeMethodDescriptionThe maximum number of records to include in each batch.The credentials needed to access the resource.The credentials needed to access the resource.maximumBatchingWindowInSeconds
(Integer maximumBatchingWindowInSeconds) The maximum length of a time to wait for events.serverRootCaCertificate
(String serverRootCaCertificate) The ARN of the Secrets Manager secret used for certification.This structure specifies the VPC subnets and security groups for the stream, and whether a public IP address is to be used.This structure specifies the VPC subnets and security groups for the stream, and whether a public IP address is to be used.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, sdkFieldNameToField, sdkFields
-
Method Details
-
batchSize
The maximum number of records to include in each batch.
- Parameters:
batchSize
- The maximum number of records to include in each batch.- Returns:
- Returns a reference to this object so that method calls can be chained together.
-
maximumBatchingWindowInSeconds
UpdatePipeSourceSelfManagedKafkaParameters.Builder maximumBatchingWindowInSeconds(Integer maximumBatchingWindowInSeconds) The maximum length of a time to wait for events.
- Parameters:
maximumBatchingWindowInSeconds
- The maximum length of a time to wait for events.- Returns:
- Returns a reference to this object so that method calls can be chained together.
-
credentials
UpdatePipeSourceSelfManagedKafkaParameters.Builder credentials(SelfManagedKafkaAccessConfigurationCredentials credentials) The credentials needed to access the resource.
- Parameters:
credentials
- The credentials needed to access the resource.- Returns:
- Returns a reference to this object so that method calls can be chained together.
-
credentials
default UpdatePipeSourceSelfManagedKafkaParameters.Builder credentials(Consumer<SelfManagedKafkaAccessConfigurationCredentials.Builder> credentials) The credentials needed to access the resource.
This is a convenience method that creates an instance of theSelfManagedKafkaAccessConfigurationCredentials.Builder
avoiding the need to create one manually viaSelfManagedKafkaAccessConfigurationCredentials.builder()
.When the
Consumer
completes,SdkBuilder.build()
is called immediately and its result is passed tocredentials(SelfManagedKafkaAccessConfigurationCredentials)
.- Parameters:
credentials
- a consumer that will call methods onSelfManagedKafkaAccessConfigurationCredentials.Builder
- Returns:
- Returns a reference to this object so that method calls can be chained together.
- See Also:
-
serverRootCaCertificate
UpdatePipeSourceSelfManagedKafkaParameters.Builder serverRootCaCertificate(String serverRootCaCertificate) The ARN of the Secrets Manager secret used for certification.
- Parameters:
serverRootCaCertificate
- The ARN of the Secrets Manager secret used for certification.- Returns:
- Returns a reference to this object so that method calls can be chained together.
-
vpc
This structure specifies the VPC subnets and security groups for the stream, and whether a public IP address is to be used.
- 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:
- Returns a reference to this object so that method calls can be chained together.
-
vpc
default UpdatePipeSourceSelfManagedKafkaParameters.Builder vpc(Consumer<SelfManagedKafkaAccessConfigurationVpc.Builder> vpc) This structure specifies the VPC subnets and security groups for the stream, and whether a public IP address is to be used.
This is a convenience method that creates an instance of theSelfManagedKafkaAccessConfigurationVpc.Builder
avoiding the need to create one manually viaSelfManagedKafkaAccessConfigurationVpc.builder()
.When the
Consumer
completes,SdkBuilder.build()
is called immediately and its result is passed tovpc(SelfManagedKafkaAccessConfigurationVpc)
.- Parameters:
vpc
- a consumer that will call methods onSelfManagedKafkaAccessConfigurationVpc.Builder
- Returns:
- Returns a reference to this object so that method calls can be chained together.
- See Also:
-