MSK - AWS Serverless Application Model
SintaksPropertiContoh

Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

MSK

Objek yang menggambarkan tipe sumber peristiwa MSK. Untuk informasi selengkapnya, lihat Menggunakan AWS Lambda MSK Amazon di Panduan AWS Lambda Pengembang.

AWS Serverless Application Model (AWS SAM) menghasilkan AWS::Lambda::EventSourceMappingsumber daya saat jenis acara ini disetel.

Sintaks

Untuk mendeklarasikan entitas ini di AWS SAM template Anda, gunakan sintaks berikut.

Properti

ConsumerGroupId

String yang mengonfigurasi bagaimana acara akan dibaca dari topik Kafka.

Tipe: String

Wajib: Tidak

AWS CloudFormation kompatibilitas: Properti ini diteruskan langsung ke AmazonManagedKafkaConfiguration properti AWS::Lambda::EventSourceMapping sumber daya.

DestinationConfig

Objek konfigurasi yang menentukan tujuan dari peristiwa setelah Lambda memprosesnya.

Gunakan properti ini untuk menentukan tujuan pemanggilan gagal dari sumber peristiwa MSK Amazon.

Jenis: DestinationConfig

Wajib: Tidak

AWS CloudFormation kompatibilitas: Properti ini diteruskan langsung ke DestinationConfig properti AWS::Lambda::EventSourceMapping sumber daya.

FilterCriteria

Objek yang mendefinisikan kriteria yang menentukan apakah Lambda harus memproses suatu peristiwa. Untuk informasi selengkapnya, lihat pemfilteran AWS Lambda acara di Panduan AWS Lambda Pengembang.

Jenis: FilterCriteria

Wajib: Tidak

AWS CloudFormation kompatibilitas: Properti ini diteruskan langsung ke FilterCriteria properti AWS::Lambda::EventSourceMapping sumber daya.

MaximumBatchingWindowInSeconds

Jumlah waktu maksimum untuk mengumpulkan rekaman sebelum memanggil fungsi, dalam hitungan detik.

Tipe: Integer

Wajib: Tidak

AWS CloudFormation kompatibilitas: Properti ini diteruskan langsung ke MaximumBatchingWindowInSeconds properti AWS::Lambda::EventSourceMapping sumber daya.

SourceAccessConfigurations

Susunan protokol autentikasi, komponen VPC, atau host virtual untuk mengamankan dan menentukan sumber peristiwa Anda.

Nilai yang valid: CLIENT_CERTIFICATE_TLS_AUTH

Jenis: Daftar SourceAccessConfiguration

Wajib: Tidak

AWS CloudFormation kompatibilitas: Properti ini diteruskan langsung ke SourceAccessConfigurations properti AWS::Lambda::EventSourceMapping sumber daya.

StartingPosition

Posisi dalam pengaliran tempat untuk mulai membaca.

  • AT_TIMESTAMP— Tentukan waktu untuk mulai membaca catatan.

  • LATEST— Baca hanya catatan baru.

  • TRIM_HORIZON— Memproses semua catatan yang tersedia.

Nilai yang valid: AT_TIMESTAMP | LATEST | TRIM_HORIZON

Tipe: String

Wajib: Tidak

AWS CloudFormation kompatibilitas: Properti ini diteruskan langsung ke StartingPosition properti AWS::Lambda::EventSourceMapping sumber daya.

StartingPositionTimestamp

Waktu untuk mulai membaca, dalam detik waktu Unix. Tentukan StartingPositionTimestamp kapan StartingPosition ditentukan sebagaiAT_TIMESTAMP.

Tipe: Ganda

Wajib: Tidak

AWS CloudFormation kompatibilitas: Properti ini diteruskan langsung ke StartingPositionTimestamp properti AWS::Lambda::EventSourceMapping sumber daya.

Stream

Amazon Resource Name (ARN) dari aliran data atau konsumen pengaliran.

Tipe: String

Wajib: Ya

AWS CloudFormation kompatibilitas: Properti ini diteruskan langsung ke EventSourceArn properti AWS::Lambda::EventSourceMapping sumber daya.

Topics

Nama topik Kafka.

Tipe: Daftar

Wajib: Ya

AWS CloudFormation kompatibilitas: Properti ini diteruskan langsung ke Topics properti AWS::Lambda::EventSourceMapping sumber daya.

Contoh

Contoh Amazon MSK untuk Klaster yang ada

Berikut ini adalah contoh jenis sumber MSK peristiwa untuk cluster MSK Amazon yang sudah ada di file Akun AWS.

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 contoh untuk Klaster yang dinyatakan dalam Templat yang sama

Berikut ini adalah contoh tipe sumber peristiwa MSK untuk klaster Amazon MSK yang dinyatakan dalam file templat yang sama.

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