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 PipeSourceSelfManagedKafkaParameters = PipeSourceSelfManagedKafkaParameters' {
- additionalBootstrapServers :: Maybe [Sensitive Text]
- batchSize :: Maybe Natural
- consumerGroupID :: Maybe (Sensitive Text)
- credentials :: Maybe SelfManagedKafkaAccessConfigurationCredentials
- maximumBatchingWindowInSeconds :: Maybe Natural
- serverRootCaCertificate :: Maybe Text
- startingPosition :: Maybe SelfManagedKafkaStartPosition
- vpc :: Maybe SelfManagedKafkaAccessConfigurationVpc
- topicName :: Sensitive Text
- newPipeSourceSelfManagedKafkaParameters :: Text -> PipeSourceSelfManagedKafkaParameters
- pipeSourceSelfManagedKafkaParameters_additionalBootstrapServers :: Lens' PipeSourceSelfManagedKafkaParameters (Maybe [Text])
- pipeSourceSelfManagedKafkaParameters_batchSize :: Lens' PipeSourceSelfManagedKafkaParameters (Maybe Natural)
- pipeSourceSelfManagedKafkaParameters_consumerGroupID :: Lens' PipeSourceSelfManagedKafkaParameters (Maybe Text)
- pipeSourceSelfManagedKafkaParameters_credentials :: Lens' PipeSourceSelfManagedKafkaParameters (Maybe SelfManagedKafkaAccessConfigurationCredentials)
- pipeSourceSelfManagedKafkaParameters_maximumBatchingWindowInSeconds :: Lens' PipeSourceSelfManagedKafkaParameters (Maybe Natural)
- pipeSourceSelfManagedKafkaParameters_serverRootCaCertificate :: Lens' PipeSourceSelfManagedKafkaParameters (Maybe Text)
- pipeSourceSelfManagedKafkaParameters_startingPosition :: Lens' PipeSourceSelfManagedKafkaParameters (Maybe SelfManagedKafkaStartPosition)
- pipeSourceSelfManagedKafkaParameters_vpc :: Lens' PipeSourceSelfManagedKafkaParameters (Maybe SelfManagedKafkaAccessConfigurationVpc)
- pipeSourceSelfManagedKafkaParameters_topicName :: Lens' PipeSourceSelfManagedKafkaParameters Text
Documentation
data PipeSourceSelfManagedKafkaParameters Source #
The parameters for using a self-managed Apache Kafka stream as a source.
See: newPipeSourceSelfManagedKafkaParameters
smart constructor.
PipeSourceSelfManagedKafkaParameters' | |
|
Instances
newPipeSourceSelfManagedKafkaParameters Source #
Create a value of PipeSourceSelfManagedKafkaParameters
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:additionalBootstrapServers:PipeSourceSelfManagedKafkaParameters'
, pipeSourceSelfManagedKafkaParameters_additionalBootstrapServers
- An array of server URLs.
$sel:batchSize:PipeSourceSelfManagedKafkaParameters'
, pipeSourceSelfManagedKafkaParameters_batchSize
- The maximum number of records to include in each batch.
$sel:consumerGroupID:PipeSourceSelfManagedKafkaParameters'
, pipeSourceSelfManagedKafkaParameters_consumerGroupID
- The name of the destination queue to consume.
$sel:credentials:PipeSourceSelfManagedKafkaParameters'
, pipeSourceSelfManagedKafkaParameters_credentials
- The credentials needed to access the resource.
$sel:maximumBatchingWindowInSeconds:PipeSourceSelfManagedKafkaParameters'
, pipeSourceSelfManagedKafkaParameters_maximumBatchingWindowInSeconds
- The maximum length of a time to wait for events.
$sel:serverRootCaCertificate:PipeSourceSelfManagedKafkaParameters'
, pipeSourceSelfManagedKafkaParameters_serverRootCaCertificate
- The ARN of the Secrets Manager secret used for certification.
$sel:startingPosition:PipeSourceSelfManagedKafkaParameters'
, pipeSourceSelfManagedKafkaParameters_startingPosition
- (Streams only) The position in a stream from which to start reading.
$sel:vpc:PipeSourceSelfManagedKafkaParameters'
, pipeSourceSelfManagedKafkaParameters_vpc
- This structure specifies the VPC subnets and security groups for the
stream, and whether a public IP address is to be used.
$sel:topicName:PipeSourceSelfManagedKafkaParameters'
, pipeSourceSelfManagedKafkaParameters_topicName
- The name of the topic that the pipe will read from.
pipeSourceSelfManagedKafkaParameters_additionalBootstrapServers :: Lens' PipeSourceSelfManagedKafkaParameters (Maybe [Text]) Source #
An array of server URLs.
pipeSourceSelfManagedKafkaParameters_batchSize :: Lens' PipeSourceSelfManagedKafkaParameters (Maybe Natural) Source #
The maximum number of records to include in each batch.
pipeSourceSelfManagedKafkaParameters_consumerGroupID :: Lens' PipeSourceSelfManagedKafkaParameters (Maybe Text) Source #
The name of the destination queue to consume.
pipeSourceSelfManagedKafkaParameters_credentials :: Lens' PipeSourceSelfManagedKafkaParameters (Maybe SelfManagedKafkaAccessConfigurationCredentials) Source #
The credentials needed to access the resource.
pipeSourceSelfManagedKafkaParameters_maximumBatchingWindowInSeconds :: Lens' PipeSourceSelfManagedKafkaParameters (Maybe Natural) Source #
The maximum length of a time to wait for events.
pipeSourceSelfManagedKafkaParameters_serverRootCaCertificate :: Lens' PipeSourceSelfManagedKafkaParameters (Maybe Text) Source #
The ARN of the Secrets Manager secret used for certification.
pipeSourceSelfManagedKafkaParameters_startingPosition :: Lens' PipeSourceSelfManagedKafkaParameters (Maybe SelfManagedKafkaStartPosition) Source #
(Streams only) The position in a stream from which to start reading.
pipeSourceSelfManagedKafkaParameters_vpc :: Lens' PipeSourceSelfManagedKafkaParameters (Maybe SelfManagedKafkaAccessConfigurationVpc) Source #
This structure specifies the VPC subnets and security groups for the stream, and whether a public IP address is to be used.
pipeSourceSelfManagedKafkaParameters_topicName :: Lens' PipeSourceSelfManagedKafkaParameters Text Source #
The name of the topic that the pipe will read from.