pipes/aws.sdk.kotlin.services.pipes.model/UpdatePipeSourceSelfManagedKafkaParameters/Builder

Builder

Properties

var batchSize: Int?

The maximum number of records to include in each batch.

var credentials: SelfManagedKafkaAccessConfigurationCredentials?

The credentials needed to access the resource.

maximumBatchingWindowInSeconds

var maximumBatchingWindowInSeconds: Int?

The maximum length of a time to wait for events.

serverRootCaCertificate

var serverRootCaCertificate: String?

The ARN of the Secrets Manager secret used for certification.

var vpc: SelfManagedKafkaAccessConfigurationVpc?

This structure specifies the VPC subnets and security groups for the stream, and whether a public IP address is to be used.

Functions

fun vpc(block: SelfManagedKafkaAccessConfigurationVpc.Builder.() -> Unit)

construct an aws.sdk.kotlin.services.pipes.model.SelfManagedKafkaAccessConfigurationVpc inside the given block