Values.PipeSourceSelfManagedKafkaParametersSourceThe 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.
type nonrec t = {topicName : KafkaTopicName.t;The name of the topic that the pipe will read from.
*)startingPosition : SelfManagedKafkaStartPosition.t option;The position in a stream from which to start reading.
*)additionalBootstrapServers : KafkaBootstrapServers.t option;An array of server URLs.
*)batchSize : LimitMax10000.t option;The maximum number of records to include in each batch.
*)maximumBatchingWindowInSeconds : MaximumBatchingWindowInSeconds.t option;The maximum length of a time to wait for events.
*)consumerGroupID : URI.t option;The name of the destination queue to consume.
*)credentials : SelfManagedKafkaAccessConfigurationCredentials.t option;The credentials needed to access the resource.
*)serverRootCaCertificate : SecretManagerArn.t option;The ARN of the Secrets Manager secret used for certification.
*)vpc : SelfManagedKafkaAccessConfigurationVpc.t option;This structure specifies the VPC subnets and security groups for the stream, and whether a public IP address is to be used.
*)}val make :
?startingPosition:??? ->
?additionalBootstrapServers:??? ->
?batchSize:??? ->
?maximumBatchingWindowInSeconds:??? ->
?consumerGroupID:??? ->
?credentials:??? ->
?serverRootCaCertificate:??? ->
?vpc:??? ->
topicName:KafkaTopicName.t ->
unit ->
tval to_value :
t ->
[> `Structure of
(string
* [> `Enum of string
| `Integer of LimitMax10000.t
| `List of [> `String of EndpointString.t ] list
| `String of KafkaTopicName.t
| `Structure of
(string
* [> `List of [> `String of SubnetId.t ] list
| `String of SecretManagerArn.t ])
list ])
list ]