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

UpdatePipeSourceSelfManagedKafkaParameters

class UpdatePipeSourceSelfManagedKafkaParameters

The parameters for using a self-managed Apache Kafka stream as a source.

Types

Link copied to clipboard
class Builder
Link copied to clipboard
object Companion

Properties

Link copied to clipboard
val batchSize: Int?

The maximum number of records to include in each batch.

Link copied to clipboard
val credentials: SelfManagedKafkaAccessConfigurationCredentials?

The credentials needed to access the resource.

Link copied to clipboard
val maximumBatchingWindowInSeconds: Int?

The maximum length of a time to wait for events.

Link copied to clipboard
val serverRootCaCertificate: String?

The ARN of the Secrets Manager secret used for certification.

Link copied to clipboard
val 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

Link copied to clipboard
Link copied to clipboard
open operator override fun equals(other: Any?): Boolean
Link copied to clipboard
open override fun hashCode(): Int
Link copied to clipboard
open override fun toString(): String