Kinesis consumer lambda example

template.yaml

AWSTemplateFormatVersion: '2010-09-09'
Transform: AWS::Serverless-2016-10-31
Description: AWS Kinesis Data Stream to AWS Lambda with Enhanced Fanout via a consumer

Resources:
  # Define an AWS Kinesis Data Stream
  KinesisStream:
    Type: "AWS::Kinesis::Stream"
    Properties:
      ShardCount: 80
  
  # Define and attach a consumer to the Kinesis Data Stream
  ApplicationConsumer:
    Type: "AWS::Kinesis::StreamConsumer"
    Properties:
      StreamARN: !GetAtt KinesisStream.Arn
      ConsumerName: ApplicationConsumer

  # Create SQS queue as a failure queue
  StreamsFailureDLQ:
    Type: AWS::SQS::Queue

  # Define an AWS Lambda and attach it to the application consumer
  ApplicationFunction:
    Type: AWS::Serverless::Function
    Properties:
      CodeUri: src/
      Runtime: nodejs12.x
      Handler: app.lambdaHandler
      Tracing: Active
      Events:
        Stream:
          Type: Kinesis
          Properties:
            Stream: !GetAtt ApplicationConsumer.ConsumerARN
            StartingPosition: LATEST
            BatchSize: 100
            DestinationConfig: 
                OnFailure: 
                  Destination: !GetAtt StreamsFailureDLQ.Arn