MSK - AWS Serverless Application Model
구문속성예

기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.

MSK

MSK 이벤트 소스 유형을 설명하는 객체. 자세한 내용은 AWS Lambda 개발자 안내서의 Amazon AWS Lambda MSK와 함께 사용을 참조하십시오.

AWS Serverless Application Model (AWS SAM) 은 이 이벤트 유형이 설정되면 AWS::Lambda::EventSourceMapping리소스를 생성합니다.

구문

AWS SAM 템플릿에서 이 엔티티를 선언하려면 다음 구문을 사용합니다.

속성

ConsumerGroupId

Kafka 주제에서 이벤트를 읽는 방법을 구성하는 문자열입니다.

타입: 문자열

필수 항목 여부: 아니요

AWS CloudFormation 호환성: 이 속성은 AWS::Lambda::EventSourceMapping 리소스의 AmazonManagedKafkaConfiguration 속성으로 직접 전달됩니다.

DestinationConfig

Lambda가 이벤트를 처리한 후 이벤트의 대상을 지정하는 구성 객체입니다.

이 속성을 사용하여 Amazon MSK 이벤트 소스에서 실패한 간접 호출의 대상을 지정합니다.

유형: DestinationConfig

필수 항목 여부: 아니요

AWS CloudFormation 호환성: 이 속성은 AWS::Lambda::EventSourceMapping 리소스의 DestinationConfig 속성으로 직접 전달됩니다.

FilterCriteria

Lambda가 이벤트를 처리해야 하는지 결정하는 기준을 정의하는 객체입니다. 자세한 내용은 AWS Lambda 개발자 가이드의 AWS Lambda 이벤트 필터링을 참조하세요.

유형: FilterCriteria

필수 항목 여부: 아니요

AWS CloudFormation 호환성: 이 속성은 AWS::Lambda::EventSourceMapping 리소스의 FilterCriteria 속성으로 직접 전달됩니다.

MaximumBatchingWindowInSeconds

함수를 호출하기 전에 기록을 수집할 최대 기간(단위: 초)입니다.

유형: 정수

필수 항목 여부: 아니요

AWS CloudFormation 호환성: 이 속성은 AWS::Lambda::EventSourceMapping 리소스의 MaximumBatchingWindowInSeconds 속성에 직접 전달됩니다.

SourceAccessConfigurations

이벤트 소스를 보호하기 위한 일련의 인증 프로토콜 또는 VPC 구성 요소입니다.

유효한 값: CLIENT_CERTIFICATE_TLS_AUTH

유형: 목록 SourceAccessConfiguration

필수 항목 여부: 아니요

AWS CloudFormation 호환성: 이 속성은 AWS::Lambda::EventSourceMapping 리소스의 SourceAccessConfigurations 속성으로 직접 전달됩니다.

StartingPosition

읽기를 시작하는 스트림 내의 위치입니다.

  • AT_TIMESTAMP - 기록 읽기를 시작할 시간을 지정합니다.

  • LATEST – 새 기록만 읽습니다.

  • TRIM_HORIZON – 사용 가능한 모든 기록을 처리합니다.

유효한 값: AT_TIMESTAMP | LATEST | TRIM_HORIZON

타입: 문자열

필수 항목 여부: 아니요

AWS CloudFormation 호환성: 이 속성은 AWS::Lambda::EventSourceMapping 리소스의 StartingPosition 속성에 직접 전달됩니다.

StartingPositionTimestamp

읽기를 시작하는 시간(유닉스 시간 초 단위)입니다. StartingPositionTimestamp 언제 StartingPosition를 AT_TIMESTAMP으로 지정할지 정의합니다.

유형: Double

필수 항목 여부: 아니요

AWS CloudFormation 호환성: 이 속성은 AWS::Lambda::EventSourceMapping 리소스의 StartingPositionTimestamp 속성에 직접 전달됩니다.

Stream

데이터 스트림 혹은 스트림 컨슈머의 Amazon 리소스 이름(ARN).

타입: 문자열

필수 항목 여부: 예

AWS CloudFormation 호환성: 이 속성은 AWS::Lambda::EventSourceMapping 리소스의 EventSourceArn 속성에 직접 전달됩니다.

Topics

Kafka 주제의 이름입니다.

유형: 목록

필수 항목 여부: 예

AWS CloudFormation 호환성: 이 속성은 AWS::Lambda::EventSourceMapping 리소스의 Topics 속성에 직접 전달됩니다.

예

기존 클러스터를 위한 Amazon MSK 예제

다음은 이미 AWS 계정에 존재하는 Amazon MSK 클러스터의 MSK 이벤트 소스 유형의 예입니다.

YAML

Events:
  MSKEvent:
    Type: MSK
    Properties:
      StartingPosition: LATEST
      Stream: arn:aws:kafka:us-east-1:012345678012:cluster/exampleClusterName/abcdefab-1234-abcd-5678-cdef0123ab01-2
      Topics:
        - MyTopic

동일한 템플릿에 선언된 클러스터에 대한 Amazon MSK 예제

다음은 동일한 템플릿 파일에 선언된 Amazon MSK 클러스터의 MSK 이벤트 소스 유형입니다.

YAML

Events:
  MSKEvent:
    Type: MSK
    Properties:
      StartingPosition: LATEST
      Stream:
        Ref: MyMskCluster   # This must be the name of an MSK cluster declared in the same template file
      Topics:
        - MyTopic