Values.PipeSourceManagedStreamingKafkaParametersSourceThe parameters for using an MSK stream as a source.
type nonrec t = {topicName : KafkaTopicName.t;The name of the topic that the pipe will read from.
*)startingPosition : MSKStartPosition.t option;The position in a stream from which to start reading.
*)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 : MSKAccessCredentials.t option;The credentials needed to access the resource.
*)}val make :
?startingPosition:??? ->
?batchSize:??? ->
?maximumBatchingWindowInSeconds:??? ->
?consumerGroupID:??? ->
?credentials:??? ->
topicName:KafkaTopicName.t ->
unit ->
tval to_value :
t ->
[> `Structure of
(string
* [> `Enum of string
| `Integer of LimitMax10000.t
| `String of KafkaTopicName.t
| `Structure of (string * [> `String of SecretManagerArn.t ]) list ])
list ]