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

PipeSourceSelfManagedKafkaParameters

class PipeSourceSelfManagedKafkaParameters

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

A self managed cluster refers to any Apache Kafka cluster not hosted by Amazon Web Services. This includes both clusters you manage yourself, as well as those hosted by a third-party provider, such as Confluent Cloud, CloudKarafka, or Redpanda. For more information, see Apache Kafka streams as a source in the Amazon EventBridge User Guide.

Types

object Companion

Properties

additionalBootstrapServers

val additionalBootstrapServers: List<String>?

An array of server URLs.

val batchSize: Int?

The maximum number of records to include in each batch.

consumerGroupId

val consumerGroupId: String?

The name of the destination queue to consume.

val credentials: SelfManagedKafkaAccessConfigurationCredentials?

The credentials needed to access the resource.

maximumBatchingWindowInSeconds

val maximumBatchingWindowInSeconds: Int?

The maximum length of a time to wait for events.

serverRootCaCertificate

val serverRootCaCertificate: String?

The ARN of the Secrets Manager secret used for certification.

startingPosition

val startingPosition: SelfManagedKafkaStartPosition?

The position in a stream from which to start reading.

val topicName: String

The name of the topic that the pipe will read from.

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

inline fun copy(block: PipeSourceSelfManagedKafkaParameters.Builder.() -> Unit = {}): PipeSourceSelfManagedKafkaParameters

open operator override fun equals(other: Any?): Boolean

open override fun hashCode(): Int

open override fun toString(): String