Package com.pulumi.aws.pipes.outputs

Class PipeSourceParametersSelfManagedKafkaParameters.Builder

java.lang.Object

com.pulumi.aws.pipes.outputs.PipeSourceParametersSelfManagedKafkaParameters.Builder

Enclosing class:

PipeSourceParametersSelfManagedKafkaParameters

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

Constructor Summary

Constructors

Constructor	Description
Builder()
Builder(PipeSourceParametersSelfManagedKafkaParameters defaults)

Method Summary

Modifier and Type	Method	Description
PipeSourceParametersSelfManagedKafkaParameters.Builder	additionalBootstrapServers(java.lang.String... additionalBootstrapServers)
PipeSourceParametersSelfManagedKafkaParameters.Builder	additionalBootstrapServers(java.util.List<java.lang.String> additionalBootstrapServers)
PipeSourceParametersSelfManagedKafkaParameters.Builder	batchSize(java.lang.Integer batchSize)
PipeSourceParametersSelfManagedKafkaParameters	build()
PipeSourceParametersSelfManagedKafkaParameters.Builder	consumerGroupId(java.lang.String consumerGroupId)
PipeSourceParametersSelfManagedKafkaParameters.Builder	credentials(PipeSourceParametersSelfManagedKafkaParametersCredentials credentials)
PipeSourceParametersSelfManagedKafkaParameters.Builder	maximumBatchingWindowInSeconds(java.lang.Integer maximumBatchingWindowInSeconds)
PipeSourceParametersSelfManagedKafkaParameters.Builder	serverRootCaCertificate(java.lang.String serverRootCaCertificate)
PipeSourceParametersSelfManagedKafkaParameters.Builder	startingPosition(java.lang.String startingPosition)
PipeSourceParametersSelfManagedKafkaParameters.Builder	topicName(java.lang.String topicName)
PipeSourceParametersSelfManagedKafkaParameters.Builder	vpc(PipeSourceParametersSelfManagedKafkaParametersVpc 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(PipeSourceParametersSelfManagedKafkaParameters defaults)

Method Detail

additionalBootstrapServers

public PipeSourceParametersSelfManagedKafkaParameters.Builder additionalBootstrapServers(@Nullable
                                                                                         java.util.List<java.lang.String> additionalBootstrapServers)

additionalBootstrapServers

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

batchSize

public PipeSourceParametersSelfManagedKafkaParameters.Builder batchSize(@Nullable
                                                                        java.lang.Integer batchSize)

consumerGroupId

public PipeSourceParametersSelfManagedKafkaParameters.Builder consumerGroupId(@Nullable
                                                                              java.lang.String consumerGroupId)

credentials

public PipeSourceParametersSelfManagedKafkaParameters.Builder credentials(@Nullable
                                                                          PipeSourceParametersSelfManagedKafkaParametersCredentials credentials)

maximumBatchingWindowInSeconds

public PipeSourceParametersSelfManagedKafkaParameters.Builder maximumBatchingWindowInSeconds(@Nullable
                                                                                             java.lang.Integer maximumBatchingWindowInSeconds)

serverRootCaCertificate

public PipeSourceParametersSelfManagedKafkaParameters.Builder serverRootCaCertificate(@Nullable
                                                                                      java.lang.String serverRootCaCertificate)

startingPosition

public PipeSourceParametersSelfManagedKafkaParameters.Builder startingPosition(@Nullable
                                                                               java.lang.String startingPosition)

topicName

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

vpc

public PipeSourceParametersSelfManagedKafkaParameters.Builder vpc(@Nullable
                                                                  PipeSourceParametersSelfManagedKafkaParametersVpc vpc)

build

public PipeSourceParametersSelfManagedKafkaParameters build()