Module Values.UpdatePipeSourceSelfManagedKafkaParametersSource

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.

Sourcetype nonrec t = {
  1. batchSize : LimitMax10000.t option;
    (*

    The maximum number of records to include in each batch.

    *)
  2. maximumBatchingWindowInSeconds : MaximumBatchingWindowInSeconds.t option;
    (*

    The maximum length of a time to wait for events.

    *)
  3. credentials : SelfManagedKafkaAccessConfigurationCredentials.t option;
    (*

    The credentials needed to access the resource.

    *)
  4. serverRootCaCertificate : SecretManagerArn.t option;
    (*

    The ARN of the Secrets Manager secret used for certification.

    *)
  5. 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.

    *)
}
Sourceval make : ?batchSize:??? -> ?maximumBatchingWindowInSeconds:??? -> ?credentials:??? -> ?serverRootCaCertificate:??? -> ?vpc:??? -> unit -> t
Sourceval to_value : t -> [> `Structure of (string * [> `Integer of LimitMax10000.t | `String of SecretManagerArn.t | `Structure of (string * [> `List of [> `String of SubnetId.t ] list | `String of SecretManagerArn.t ]) list ]) list ]
Sourceval to_query : t -> Awso.Client.Query.t
Sourceval of_xml : Awso.Xml.t -> t
Sourceval of_string : string -> t
Sourceval of_json : Yojson.Safe.t -> t
Sourceval to_json : t -> Yojson.Safe.t