Lambda Event Source Mapping
Stream / queue → Lambda invocation poller.
Configuration
Section titled “Configuration”| Setting | Type | Required | Default |
|---|---|---|---|
| Event source ARN | Text | — | — |
| Lambda ARN | Text | — | — |
| Starting position (Kinesis/DDB) Options: Trim horizon, Latest, At timestamp | Choice | — | — |
| Starting timestamp (ISO) | Text | — | — |
| Batch size | Number | — | 10 |
| Max batching window (s) | Number | — | 0 |
| Max concurrency | Number | — | — |
| Parallelization factor | Number | — | — |
| Max record age (s) | Number | — | — |
| Max retry attempts | Number | — | -1 |
| Bisect batch on error | Toggle | — | false |
| Tumbling window (s) | Number | — | — |
| On-failure destination ARN | Text | — | — |
| Function response types | List | — | — |
| Enabled Options: Enabled, Disabled | Choice | — | true |
| Filter criteria (JSON) | Text | — | — |
| MSK / RabbitMQ queues | List | — | — |
| Kafka topics | List | — | — |
| MSK consumer group Options: Provide consumer group, Default | Choice | — | — |
| Consumer group ID | Text | — | — |
| Tags | Key–value | — | — |
Connections
Section titled “Connections”| Socket | Direction | Accepts | Terraform arg |
|---|---|---|---|
| Source (SQS / Kinesis / DDB) | Input | aws.sqs, aws.kinesis-stream, aws.dynamodb, aws.msk-cluster | event_source_arn |
| On-failure destination | Input | aws.sqs, aws.sns | destination_config.on_failure.destination_arn |
| Function | Output | aws.lambda | function_name |