EventSourceMapping

lambda.services.k8s.aws/v1alpha1

Metadata#

Spec#

amazonManagedKafkaEventSourceConfig: 
  consumerGroupID: string
batchSize: integer
bisectBatchOnFunctionError: boolean
destinationConfig: 
  onFailure: 
    destination: string
  onSuccess: 
    destination: string
enabled: boolean
eventSourceARN: string
eventSourceRef: 
  from: 
    name: string
filterCriteria: 
  filters:
  - pattern: string
functionName: string
functionRef: 
  from: 
    name: string
functionResponseTypes:
- string
maximumBatchingWindowInSeconds: integer
maximumRecordAgeInSeconds: integer
maximumRetryAttempts: integer
parallelizationFactor: integer
queueRefs:
  from: 
    name: string
queues:
- string
scalingConfig: 
  maximumConcurrency: integer
selfManagedEventSource: 
  endpoints: {}
selfManagedKafkaEventSourceConfig: 
  consumerGroupID: string
sourceAccessConfigurations:
- type_: string
  uRI: string
startingPosition: string
startingPositionTimestamp: string
topics:
- string
tumblingWindowInSeconds: integer

from:
  name: my-api || **queueRefs.[].from**<br/>Optional | **object**<br/>AWSResourceReference provides all the values necessary to reference another<br/>k8s resource for finding the identifier(Id/ARN/Name) |

| queueRefs.[].from.name
Optional | string
| | queues
Optional | array
(MQ) The name of the Amazon MQ broker destination queue to consume. | | queues.[]
Required | string
|| scalingConfig
Optional | object
(Amazon SQS only) The scaling configuration for the event source. For more
information, see Configuring maximum concurrency for Amazon SQS event sources
(https://docs.aws.amazon.com/lambda/latest/dg/with-sqs.html#events-sqs-max-concurrency). | | scalingConfig.maximumConcurrency
Optional | integer
| | selfManagedEventSource
Optional | object
The self-managed Apache Kafka cluster to receive records from. | | selfManagedEventSource.endpoints
Optional | object
| | selfManagedKafkaEventSourceConfig
Optional | object
Specific configuration settings for a self-managed Apache Kafka event source. | | selfManagedKafkaEventSourceConfig.consumerGroupID
Optional | string
| | sourceAccessConfigurations
Optional | array
An array of authentication protocols or VPC components required to secure
your event source. | | sourceAccessConfigurations.[]
Required | object
To secure and define access to your event source, you can specify the authentication protocol, VPC components, or virtual host. || **sourceAccessConfigurations.[].type_**
Optional | **string**
| | **sourceAccessConfigurations.[].uRI**
Optional | **string**
| | **startingPosition**
Optional | **string**
The position in a stream from which to start reading. Required for Amazon
Kinesis, Amazon DynamoDB, and Amazon MSK Streams sources. AT_TIMESTAMP is
supported only for Amazon Kinesis streams. | | **startingPositionTimestamp**
Optional | **string**
With StartingPosition set to AT_TIMESTAMP, the time from which to start reading. | | **topics**
Optional | **array**
The name of the Kafka topic. | | **topics.[]**
Required | **string**
|| **tumblingWindowInSeconds**
Optional | **integer**
(Streams only) The duration in seconds of a processing window. The range
is between 1 second and 900 seconds. |

Status#

ackResourceMetadata: 
  arn: string
  ownerAccountID: string
  region: string
conditions:
- lastTransitionTime: string
  message: string
  reason: string
  status: string
  type: string
functionARN: string
lastModified: string
lastProcessingResult: string
state: string
stateTransitionReason: string
uuid: string