Copyright | (c) 2013-2023 Brendan Hay |
---|---|
License | Mozilla Public License, v. 2.0. |
Maintainer | Brendan Hay |
Stability | auto-generated |
Portability | non-portable (GHC extensions) |
Safe Haskell | Safe-Inferred |
Language | Haskell2010 |
Synopsis
- data PipeSourceManagedStreamingKafkaParameters = PipeSourceManagedStreamingKafkaParameters' {}
- newPipeSourceManagedStreamingKafkaParameters :: Text -> PipeSourceManagedStreamingKafkaParameters
- pipeSourceManagedStreamingKafkaParameters_batchSize :: Lens' PipeSourceManagedStreamingKafkaParameters (Maybe Natural)
- pipeSourceManagedStreamingKafkaParameters_consumerGroupID :: Lens' PipeSourceManagedStreamingKafkaParameters (Maybe Text)
- pipeSourceManagedStreamingKafkaParameters_credentials :: Lens' PipeSourceManagedStreamingKafkaParameters (Maybe MSKAccessCredentials)
- pipeSourceManagedStreamingKafkaParameters_maximumBatchingWindowInSeconds :: Lens' PipeSourceManagedStreamingKafkaParameters (Maybe Natural)
- pipeSourceManagedStreamingKafkaParameters_startingPosition :: Lens' PipeSourceManagedStreamingKafkaParameters (Maybe MSKStartPosition)
- pipeSourceManagedStreamingKafkaParameters_topicName :: Lens' PipeSourceManagedStreamingKafkaParameters Text
Documentation
data PipeSourceManagedStreamingKafkaParameters Source #
The parameters for using an MSK stream as a source.
See: newPipeSourceManagedStreamingKafkaParameters
smart constructor.
PipeSourceManagedStreamingKafkaParameters' | |
|
Instances
newPipeSourceManagedStreamingKafkaParameters Source #
Create a value of PipeSourceManagedStreamingKafkaParameters
with all optional fields omitted.
Use generic-lens or optics to modify other optional fields.
The following record fields are available, with the corresponding lenses provided for backwards compatibility:
$sel:batchSize:PipeSourceManagedStreamingKafkaParameters'
, pipeSourceManagedStreamingKafkaParameters_batchSize
- The maximum number of records to include in each batch.
$sel:consumerGroupID:PipeSourceManagedStreamingKafkaParameters'
, pipeSourceManagedStreamingKafkaParameters_consumerGroupID
- The name of the destination queue to consume.
$sel:credentials:PipeSourceManagedStreamingKafkaParameters'
, pipeSourceManagedStreamingKafkaParameters_credentials
- The credentials needed to access the resource.
$sel:maximumBatchingWindowInSeconds:PipeSourceManagedStreamingKafkaParameters'
, pipeSourceManagedStreamingKafkaParameters_maximumBatchingWindowInSeconds
- The maximum length of a time to wait for events.
$sel:startingPosition:PipeSourceManagedStreamingKafkaParameters'
, pipeSourceManagedStreamingKafkaParameters_startingPosition
- (Streams only) The position in a stream from which to start reading.
$sel:topicName:PipeSourceManagedStreamingKafkaParameters'
, pipeSourceManagedStreamingKafkaParameters_topicName
- The name of the topic that the pipe will read from.
pipeSourceManagedStreamingKafkaParameters_batchSize :: Lens' PipeSourceManagedStreamingKafkaParameters (Maybe Natural) Source #
The maximum number of records to include in each batch.
pipeSourceManagedStreamingKafkaParameters_consumerGroupID :: Lens' PipeSourceManagedStreamingKafkaParameters (Maybe Text) Source #
The name of the destination queue to consume.
pipeSourceManagedStreamingKafkaParameters_credentials :: Lens' PipeSourceManagedStreamingKafkaParameters (Maybe MSKAccessCredentials) Source #
The credentials needed to access the resource.
pipeSourceManagedStreamingKafkaParameters_maximumBatchingWindowInSeconds :: Lens' PipeSourceManagedStreamingKafkaParameters (Maybe Natural) Source #
The maximum length of a time to wait for events.
pipeSourceManagedStreamingKafkaParameters_startingPosition :: Lens' PipeSourceManagedStreamingKafkaParameters (Maybe MSKStartPosition) Source #
(Streams only) The position in a stream from which to start reading.
pipeSourceManagedStreamingKafkaParameters_topicName :: Lens' PipeSourceManagedStreamingKafkaParameters Text Source #
The name of the topic that the pipe will read from.