Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.
# SelfManagedKafka
Objek yang menggambarkan tipe sumber peristiwa `SelfManagedKafka`. *Untuk informasi selengkapnya, lihat [Menggunakan AWS Lambda Apache Kafka yang dikelola sendiri di Panduan](https://docs.aws.amazon.com/lambda/latest/dg/with-kafka.html) Pengembang.AWS Lambda *
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.md#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-selfmanagedkafka-batchsize): Integer
[BisectBatchOnFunctionError](#sam-function-selfmanagedkafka-bisectbatchonfunctionerror): Boolean
[ConsumerGroupId](#sam-function-selfmanagedkafka-consumergroupid): String
DestinationConfig: [DestinationConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-destinationconfig.html)
[Enabled](#sam-function-selfmanagedkafka-enabled): Boolean
[FilterCriteria](#sam-function-selfmanagedkafka-filtercriteria): [FilterCriteria](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-filtercriteria.html)
[KafkaBootstrapServers](#sam-function-selfmanagedkafka-kafkabootstrapservers): List
[FunctionResponseTypes](#sam-function-selfmanagedkafka-functionresponsetypes): List
KmsKeyArn: String
[LoggingConfig](#sam-function-selfmanagedkafka-loggingconfig): LoggingConfig
[MaximumRecordAgeInSeconds](#sam-function-selfmanagedkafka-maximumrecordageinseconds): Integer
[MaximumRetryAttempts](#sam-function-selfmanagedkafka-maximumretryattempts): Integer
[MetricsConfig](#sam-function-selfmanagedkafka-metricsconfig): MetricsConfig
[ProvisionedPollerConfig](#sam-function-selfmanagedkafka-provisionedpollerconfig): [ProvisionedPollerConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-provisionedpollerconfig)
[SchemaRegistryConfig](#sam-function-selfmanagedkafka-schemaregistryconfig): [SchemaRegistryConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-schemaregistryconfig.html)
[SourceAccessConfigurations](#sam-function-selfmanagedkafka-sourceaccessconfigurations): [SourceAccessConfigurations](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html#cfn-lambda-eventsourcemapping-sourceaccessconfigurations)
StartingPosition: String
StartingPositionTimestamp: Double
[Topics](#sam-function-selfmanagedkafka-topics): List
```
## Sifat-sifat
`BatchSize`
Jumlah maksimum rekaman di setiap batch yang Lambda tarik dari aliran Anda dan dikirim ke fungsi Anda.
*Tipe*: Integer
*Wajib*: Tidak
*Default*: 100
*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.
*Minimal*: `1`
*Maksimum*: `10000`
`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 `[SelfManagedKafkaEventSourceConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-selfmanagedkafkaeventsourceconfig)` 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 acara Kafka yang dikelola sendiri.
*Jenis*: [DestinationConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-destinationconfig.html)
*Wajib*: Tidak
*CloudFormation kompatibilitas*: Properti ini diteruskan langsung ke `[ DestinationConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html#cfn-lambda-eventsourcemapping-destinationconfig)` 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 untuk 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-resource-lambda-eventsourcemapping.html#cfn-lambda-eventsourcemapping-filtercriteria)` properti `AWS::Lambda::EventSourceMapping` sumber daya.
`KafkaBootstrapServers`
Daftar server bootstrap untuk broker Kafka Anda. Sertakan port, misalnya `broker.example.com:xxxx`
*Tipe*: Daftar
*Wajib*: Tidak
*CloudFormation kompatibilitas*: Properti ini unik AWS SAM dan tidak memiliki CloudFormation padanan.
`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.
`LoggingConfig`
Konfigurasi logging untuk sumber acara Anda.
*Jenis*: [LoggingConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-loggingconfig)
*Wajib*: Tidak
*CloudFormation kompatibilitas*: Properti ini diteruskan langsung ke `[LoggingConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html#cfn-lambda-eventsourcemapping-loggingconfig)` 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.
`MetricsConfig`
Konfigurasi metrik untuk sumber acara Anda.
*Jenis*: [MetricsConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-metricsconfig)
*Wajib*: Tidak
*CloudFormation kompatibilitas*: Properti ini diteruskan langsung ke `[MetricsConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html#cfn-lambda-eventsourcemapping-metricsconfig)` 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.
`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-selfmanagedkafka-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-resource-lambda-eventsourcemapping.html#cfn-lambda-eventsourcemapping-provisionedpollerconfig)` properti `AWS::Lambda::EventSourceMapping` sumber daya.
`SchemaRegistryConfig`
Konfigurasi untuk menggunakan registri skema dengan sumber acara Kafka yang dikelola sendiri.
Fitur ini `ProvisionedPollerConfig` perlu dikonfigurasi.
*Jenis*: [SchemaRegistryConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-schemaregistryconfig)
*Wajib*: Tidak
*CloudFormation kompatibilitas:* Properti ini diteruskan langsung ke `[SelfManagedKafkaEventSourceConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-selfmanagedkafkaeventsourceconfig)` 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*: `BASIC_AUTH | CLIENT_CERTIFICATE_TLS_AUTH | SASL_SCRAM_256_AUTH | SASL_SCRAM_512_AUTH | SERVER_ROOT_CA_CERTIFICATE`
*Jenis*: Daftar [SourceAccessConfiguration](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-sourceaccessconfiguration)
*Wajib*: Ya
*CloudFormation kompatibilitas:* Properti ini adalah bagian dari `[SelfManagedKafkaEventSourceConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-selfmanagedkafkaeventsourceconfig)` 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` \$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.
`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
### Pengaturan 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
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: 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}
MyKafkaProcessor:
Type: AWS::Serverless::Function
Properties:
Runtime: nodejs18.x
Handler: index.handler
CodeUri: ${codeuri}
Role:
Fn::GetAtt: [MyLambdaExecutionRole, Arn]
Events:
SelfManagedKafkaEvent:
Type: SelfManagedKafka
Properties:
KafkaBootstrapServers:
- my-kafka-broker-1:9092
- my-kafka-broker-2:9092
Topics:
- SchemaRegistryTestTopic
StartingPosition: LATEST
SourceAccessConfigurations:
- Type: VPC_SUBNET
URI: subnet:subnet-12345678
- Type: VPC_SECURITY_GROUP
URI: security_group:sg-12345678
- Type: BASIC_AUTH
URI: !Sub arn:${AWS::Partition}:secretsmanager:us-west-2:123456789012:secret:my-path/my-secret-name-1a2b3c
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
```
### Sumber acara Kafka yang dikelola sendiri
Berikut adalah contoh peristiwa dari tipe sumber peristiwa `SelfManagedKafka`.
#### YAML
```
Events:
SelfManagedKafkaEvent:
Type: SelfManagedKafka
Properties:
BatchSize: 1000
Enabled: true
KafkaBootstrapServers:
- abc.xyz.com:xxxx
SourceAccessConfigurations:
- Type: BASIC_AUTH
URI: arn:aws:secretsmanager:us-west-2:123456789012:secret:my-path/my-secret-name-1a2b3c
Topics:
- MyKafkaTopic
```
### Sumber Acara Kafka yang dikelola sendiri dengan AWS Glue Schema Registry
Berikut ini adalah contoh dari jenis sumber `SelfManagedKafka` peristiwa dikonfigurasi dengan AWS Glue Schema Registry.
```
Events:
SelfManagedKafkaEvent:
Type: SelfManagedKafka
Properties:
KafkaBootstrapServers:
- abc.xyz.com:9092
Topics:
- SchemaRegistryTestTopic
StartingPosition: LATEST
ProvisionedPollerConfig:
MinimumPollers: 1
SchemaRegistryConfig:
SchemaRegistryURI: !Sub arn:${AWS::Partition}:glue:us-west-2:123456789012:registry/myregistry
EventRecordFormat: JSON
SchemaValidationConfigs:
- Attribute: KEY
- Attribute: VALUE
SourceAccessConfigurations:
- Type: VPC_SUBNET
URI: subnet:subnet-12345678
- Type: VPC_SECURITY_GROUP
URI: security_group:sg-12345678
```
### Sumber Acara Kafka yang dikelola sendiri dengan Registri Skema Konfluen
Berikut ini adalah contoh dari jenis sumber `SelfManagedKafka` peristiwa dikonfigurasi dengan Confluent Schema Registry.
```
Events:
SelfManagedKafkaEvent:
Type: SelfManagedKafka
Properties:
KafkaBootstrapServers:
- abc.xyz.com:9092
Topics:
- SchemaRegistryTestTopic
StartingPosition: LATEST
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
SourceAccessConfigurations:
- Type: VPC_SUBNET
URI: subnet:subnet-12345678
- Type: VPC_SECURITY_GROUP
URI: security_group:sg-12345678
- Type: BASIC_AUTH
URI: !Sub arn:${AWS::Partition}:secretsmanager:us-west-2:123456789012:secret:kafka-secret
```