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](https://docs.aws.amazon.com/lambda/latest/dg/with-msk.html) di *Panduan AWS Lambda Pengembang*.
AWS Serverless Application Model (AWS SAM) menghasilkan [https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html)sumber daya saat jenis acara ini disetel.
Untuk menggunakan Schema Registry, Anda perlu menentukan izin peran IAM tertentu untuk fungsi Anda. Lihat [Penyiapan lengkap dengan peran IAM](#sam-property-function-msk-example-complete) untuk contoh konfigurasi yang diperlukan.
## Sintaksis
Untuk mendeklarasikan entitas ini di AWS SAM template Anda, gunakan sintaks berikut.
### YAML
```
[BatchSize](#sam-function-msk-batchsize): Integer
[BisectBatchOnFunctionError](#sam-function-msk-bisectbatchonfunctionerror): Boolean
[ConsumerGroupId](#sam-function-msk-consumergroupid): String
DestinationConfig: [DestinationConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-destinationconfig.html)
[Enabled](#sam-function-msk-enabled): Boolean
[FilterCriteria](#sam-function-msk-filtercriteria): [FilterCriteria](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-filtercriteria.html)
[FunctionResponseTypes](#sam-function-msk-functionresponsetypes): List
KmsKeyArn: String
[MaximumBatchingWindowInSeconds](#sam-function-msk-maximumbatchingwindowinseconds): Integer
[MaximumRecordAgeInSeconds](#sam-function-msk-maximumrecordageinseconds): Integer
[MaximumRetryAttempts](#sam-function-msk-maximumretryattempts): Integer
[LoggingConfig](#sam-function-msk-loggingconfig): [LoggingConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-loggingconfig.html)
[MetricsConfig](#sam-function-msk-metricsconfig): [MetricsConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-metricsconfig.html)
[ProvisionedPollerConfig](#sam-function-msk-provisionedpollerconfig): [ProvisionedPollerConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-provisionedpollerconfig)
[SchemaRegistryConfig](#sam-function-msk-schemaregistryconfig): [SchemaRegistryConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-schemaregistryconfig.html)
SourceAccessConfigurations: [SourceAccessConfigurations](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html#cfn-lambda-eventsourcemapping-sourceaccessconfigurations)
[StartingPosition](#sam-function-msk-startingposition): String
StartingPositionTimestamp: Double
[Stream](#sam-function-msk-stream): String
[Topics](#sam-function-msk-topics): List
```
## Sifat-sifat
`BatchSize`
Jumlah maksimum rekaman di setiap batch yang Lambda tarik dari aliran atau antrian Anda dan dikirim ke fungsi Anda. Lambda meneruskan semua catatan dalam batch ke fungsi dalam satu panggilan, hingga batas payload untuk pemanggilan sinkron (6 MB).
*Default*: 100
*Rentang Valid*: Nilai minimum 1. Nilai maksimum 10.000.
*Tipe*: Integer
*Wajib*: Tidak
*CloudFormation kompatibilitas*: Properti ini diteruskan langsung ke `[BatchSize](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html#cfn-lambda-eventsourcemapping-batchsize)` properti `AWS::Lambda::EventSourceMapping` sumber daya.
`BisectBatchOnFunctionError`
Jika fungsi mengembalikan kesalahan, bagi batch menjadi dua dan coba lagi.
*Tipe*: Boolean
*Wajib*: Tidak
*CloudFormation kompatibilitas*: Properti ini diteruskan langsung ke `[BisectBatchOnFunctionError](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html#cfn-lambda-eventsourcemapping-bisectbatchonfunctionerror)` properti `AWS::Lambda::EventSourceMapping` sumber daya.
`ConsumerGroupId`
String yang mengonfigurasi bagaimana acara akan dibaca dari topik Kafka.
*Tipe*: String
*Wajib*: Tidak
*CloudFormation kompatibilitas*: Properti ini diteruskan langsung ke `[AmazonManagedKafkaConfiguration](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html)` 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](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html#cfn-lambda-eventsourcemapping-destinationconfig)
*Wajib*: Tidak
*CloudFormation kompatibilitas*: Properti ini diteruskan langsung ke `[ DestinationConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-destinationconfig.html)` properti `AWS::Lambda::EventSourceMapping` sumber daya.
`Enabled`
Menonaktifkan pemetaan sumber peristiwa untuk menjeda polling dan pemanggilan.
*Tipe*: Boolean
*Wajib*: Tidak
*CloudFormation kompatibilitas*: Properti ini diteruskan langsung ke `[Enabled](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html#cfn-lambda-eventsourcemapping-enabled)` 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](https://docs.aws.amazon.com/lambda/latest/dg/invocation-eventfiltering.html) di *Panduan AWS Lambda Pengembang*.
*Jenis*: [FilterCriteria](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-filtercriteria.html)
*Wajib*: Tidak
*CloudFormation kompatibilitas*: Properti ini diteruskan langsung ke `[FilterCriteria](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-filtercriteria.html)` properti `AWS::Lambda::EventSourceMapping` sumber daya.
`FunctionResponseTypes`
Daftar tipe jawaban saat ini yang diterapkan ke pemetaan sumber peristiwa. Untuk informasi selengkapnya, lihat [Melaporkan kegagalan item batch](https://docs.aws.amazon.com/lambda/latest/dg/kafka-retry-configurations.html) di *Panduan Developer AWS Lambda *.
*Nilai yang valid*: `ReportBatchItemFailures`
*Tipe*: Daftar
*Wajib*: Tidak
*CloudFormation kompatibilitas*: Properti ini diteruskan langsung ke `[FunctionResponseTypes](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html#cfn-lambda-eventsourcemapping-functionresponsetypes)` properti `AWS::Lambda::EventSourceMapping` sumber daya.
`KmsKeyArn`
Nama Sumber Daya Amazon (ARN) dari kunci untuk mengenkripsi informasi yang terkait dengan acara ini.
*Tipe*: String
*Wajib*: Tidak
*CloudFormation kompatibilitas*: Properti ini diteruskan langsung ke `[KmsKeyArn](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html#cfn-lambda-eventsourcemapping-kmskeyarn)` properti `AWS::Lambda::EventSourceMapping` sumber daya.
`MaximumBatchingWindowInSeconds`
Jumlah waktu maksimum untuk mengumpulkan rekaman sebelum memanggil fungsi, dalam hitungan detik.
*Tipe*: Integer
*Wajib*: Tidak
*CloudFormation kompatibilitas*: Properti ini diteruskan langsung ke `[MaximumBatchingWindowInSeconds](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html#cfn-lambda-eventsourcemapping-maximumbatchingwindowinseconds)` properti `AWS::Lambda::EventSourceMapping` sumber daya.
`MaximumRecordAgeInSeconds`
Periode permintaan maksimum yang dikirimkan Lambda ke fungsi untuk diproses.
*Tipe*: Integer
*Wajib*: Tidak
*CloudFormation kompatibilitas*: Properti ini diteruskan langsung ke `[MaximumRecordAgeInSeconds](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html#cfn-lambda-eventsourcemapping-maximumrecordageinseconds)` properti `AWS::Lambda::EventSourceMapping` sumber daya.
`MaximumRetryAttempts`
Jumlah waktu maksimum untuk mencoba kembali saat fungsi mengembalikan kesalahan.
*Tipe*: Integer
*Wajib*: Tidak
*CloudFormation kompatibilitas*: Properti ini diteruskan langsung ke `[MaximumRetryAttempts](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html#cfn-lambda-eventsourcemapping-maximumretryattempts)` properti `AWS::Lambda::EventSourceMapping` sumber daya.
`LoggingConfig`
Objek konfigurasi yang menentukan konfigurasi logging untuk pemetaan sumber peristiwa.
*Jenis*: [LoggingConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-loggingconfig.html)
*Wajib*: Tidak
*CloudFormation kompatibilitas*: Properti ini diteruskan langsung ke `[LoggingConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-loggingconfig.html)` properti `AWS::Lambda::EventSourceMapping` sumber daya.
`MetricsConfig`
Objek konfigurasi yang menentukan konfigurasi metrik untuk pemetaan sumber peristiwa.
*Jenis*: [MetricsConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-metricsconfig.html)
*Wajib*: Tidak
*CloudFormation kompatibilitas*: Properti ini diteruskan langsung ke `[MetricsConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-metricsconfig.html)` properti `AWS::Lambda::EventSourceMapping` sumber daya.
`ProvisionedPollerConfig`
Konfigurasi untuk meningkatkan jumlah poller yang digunakan untuk menghitung pemetaan sumber peristiwa. Konfigurasi ini memungkinkan minimal 1 poller dan maksimum 2000 poller. Sebagai contoh, lihat[ProvisionedPollerConfig contoh](#sam-property-function-msk-example-provisionedpollerconfig).
*Jenis*: [ProvisionedPollerConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-provisionedpollerconfig)
*Wajib*: Tidak
*CloudFormation kompatibilitas*: Properti ini diteruskan langsung ke `[ProvisionedPollerConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-provisionedpollerconfig)` properti `AWS::Lambda::EventSourceMapping` sumber daya.
`SchemaRegistryConfig`
Konfigurasi untuk menggunakan registri skema dengan sumber acara Kafka.
Fitur ini `ProvisionedPollerConfig` perlu dikonfigurasi.
*Jenis*: SchemaRegistryConfig
*Wajib*: Tidak
*CloudFormation kompatibilitas:* Properti ini diteruskan langsung ke `[AmazonManagedKafkaEventSourceConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-amazonmanagedkafkaeventsourceconfig)` 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](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-sourceaccessconfiguration.html)
*Wajib*: Tidak
*CloudFormation kompatibilitas:* Properti ini adalah bagian dari [AmazonManagedKafkaEventSourceConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/TemplateReference/aws-properties-lambda-eventsourcemapping-amazonmanagedkafkaeventsourceconfig)properti sumber daya. `AWS::Lambda::EventSourceMapping`
`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` \$1 `LATEST` \$1 `TRIM_HORIZON`
*Tipe*: String
*Wajib*: Tidak
*CloudFormation kompatibilitas*: Properti ini diteruskan langsung ke `[StartingPosition](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html#cfn-lambda-eventsourcemapping-startingposition)` properti `AWS::Lambda::EventSourceMapping` sumber daya.
`StartingPositionTimestamp`
Waktu untuk mulai membaca, dalam detik waktu Unix. Tentukan `StartingPositionTimestamp` kapan `StartingPosition` ditentukan sebagai`AT_TIMESTAMP`.
*Tipe*: Ganda
*Wajib*: Tidak
*CloudFormation kompatibilitas*: Properti ini diteruskan langsung ke `[StartingPositionTimestamp](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html#cfn-lambda-eventsourcemapping-startingpositiontimestamp)` properti `AWS::Lambda::EventSourceMapping` sumber daya.
`Stream`
Amazon Resource Name (ARN) dari aliran data atau konsumen pengaliran.
*Tipe*: String
*Wajib*: Ya
*CloudFormation kompatibilitas*: Properti ini diteruskan langsung ke `[EventSourceArn](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html#cfn-lambda-eventsourcemapping-eventsourcearn)` properti `AWS::Lambda::EventSourceMapping` sumber daya.
`Topics`
Nama topik Kafka.
*Tipe*: Daftar
*Wajib*: Ya
*CloudFormation kompatibilitas*: Properti ini diteruskan langsung ke `[Topics](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html#cfn-lambda-eventsourcemapping-topics)` properti `AWS::Lambda::EventSourceMapping` sumber daya.
## Contoh
### Penyiapan lengkap dengan peran IAM
Contoh berikut menunjukkan penyiapan lengkap termasuk konfigurasi peran IAM yang diperlukan untuk menggunakan Schema Registry:
```
Parameters:
PreCreatedSubnetOne:
Type: String
PreCreatedSubnetTwo:
Type: String
MskClusterName4:
Type: String
Resources:
MyLambdaExecutionRole:
Type: AWS::IAM::Role
Properties:
AssumeRolePolicyDocument:
Version: '2012-10-17 '
Statement:
- Action: [sts:AssumeRole]
Effect: Allow
Principal:
Service: [lambda.amazonaws.com]
Policies:
- PolicyName: KafkaClusterPermissions
PolicyDocument:
Statement:
- Action: [kafka:DescribeClusterV2, kafka:GetBootstrapBrokers]
Effect: Allow
Resource: 'arn:aws:kafka:us-east-1:123456789012:cluster/*'
- PolicyName: KafkaAuthPolicy
PolicyDocument:
Statement:
- Action: [secretsmanager:GetSecretValue, kms:Decrypt]
Effect: "Allow"
Resource: ['arn:aws:secretsmanager:us-west-2:123456789012:secret:kafkaSecret-******',
'arn:aws:kms:us-west-2:123456789012:key/keyId']
- PolicyName: ENIPolicy
PolicyDocument:
Statement:
- Action: [ec2:CreateNetworkInterface,
ec2:DescribeNetworkInterfaces, ec2:DescribeVpcs, ec2:DeleteNetworkInterface,
ec2:DescribeSubnets, ec2:DescribeSecurityGroups]
Effect: Allow
Resource: '*'
- PolicyName: SchemaRegistryPolicy
PolicyDocument:
Statement:
- Action: [glue:GetRegistry]
Effect: Allow
Resource: 'arn:aws:glue:{region}:{account-id}:registry/{registry-name}'
- PolicyName: SchemaVersionsPolicy
PolicyDocument:
Statement:
- Action: [glue:GetSchemaVersions]
Effect: Allow
Resource: '*'
ManagedPolicyArns:
- !Sub arn:${AWS::Partition}:iam::aws:policy/service-role/AWSLambdaBasicExecutionRole
Tags:
- {Value: SAM, Key: lambda:createdBy}
MyMskCluster:
Type: AWS::MSK::Cluster
Properties:
BrokerNodeGroupInfo:
ClientSubnets:
- Ref: PreCreatedSubnetOne
- Ref: PreCreatedSubnetTwo
InstanceType: kafka.t3.small
StorageInfo:
EBSStorageInfo:
VolumeSize: 1
ClusterName:
Ref: MskClusterName4
KafkaVersion: 3.8.x
NumberOfBrokerNodes: 2
MyMskStreamProcessor:
Type: AWS::Serverless::Function
Properties:
Runtime: nodejs18.x
Handler: index.handler
CodeUri: ${codeuri}
Role:
Fn::GetAtt: [MyLambdaExecutionRole, Arn]
Events:
MyMskEvent:
Type: MSK
Properties:
StartingPosition: LATEST
Stream:
Ref: MyMskCluster
SourceAccessConfigurations:
- Type: SASL_SCRAM_512_AUTH
URI: !Sub arn:${AWS::Partition}:secretsmanager:us-west-2:123456789012:secret:my-path/my-secret-name-1a2b3c
Topics:
- SchemaRegistryTestTopic
ProvisionedPollerConfig:
MinimumPollers: 1
SchemaRegistryConfig:
AccessConfigs:
- Type: BASIC_AUTH
URI: !Sub arn:${AWS::Partition}:secretsmanager:us-west-2:123456789012:secret:my-path/my-secret-name-1a2b3c
SchemaValidationConfigs:
- Attribute: KEY
EventRecordFormat: JSON
SchemaRegistryURI: !Sub arn:${AWS::Partition}:glue:us-west-2:123456789012:registry/myregistry
```
### ProvisionedPollerConfig contoh
```
ProvisionedPollerConfig:
MinimumPollers: 1
MaximumPollers: 200
```
### Contoh Amazon MSK untuk Klaster yang ada
Berikut ini adalah contoh jenis sumber `MSK` peristiwa untuk kluster 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
```
#### Sumber Acara MSK dengan Registri Skema
Berikut ini adalah contoh dari jenis sumber `MSK` peristiwa dikonfigurasi dengan registri skema.
```
Events:
MSKEvent:
Type: MSK
Properties:
StartingPosition: LATEST
Stream:
Ref: MyMskCluster
Topics:
- SchemaRegistryTestTopic
ProvisionedPollerConfig:
MinimumPollers: 1
SchemaRegistryConfig:
SchemaRegistryURI: !Sub arn:${AWS::Partition}:glue:us-west-2:123456789012:registry/myregistry
EventRecordFormat: JSON
SchemaValidationConfigs:
- Attribute: KEY
- Attribute: VALUE
```
#### Sumber Acara MSK dengan Registri Skema Konfluen
Berikut ini adalah contoh dari jenis sumber `MSK` peristiwa dikonfigurasi dengan Confluent Schema Registry.
```
Events:
MSKEvent:
Type: MSK
Properties:
StartingPosition: LATEST
Stream:
Ref: MyMskCluster
Topics:
- SchemaRegistryTestTopic
ProvisionedPollerConfig:
MinimumPollers: 1
SchemaRegistryConfig:
SchemaRegistryURI: https://my-schema-registry.confluent.cloud
AccessConfigs:
- Type: BASIC_AUTH
URI: !Sub arn:${AWS::Partition}:secretsmanager:us-west-2:123456789012:secret:my-secret
EventRecordFormat: JSON
SchemaValidationConfigs:
- Attribute: KEY
- Attribute: VALUE
```