Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.
# MSK
L'oggetto che descrive un tipo di sorgente di `MSK` eventi. Per ulteriori informazioni, consulta [Using AWS Lambda with Amazon MSK](https://docs.aws.amazon.com/lambda/latest/dg/with-msk.html) nella *AWS Lambda Developer Guide*.
AWS Serverless Application Model (AWS SAM) genera una [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)risorsa quando viene impostato questo tipo di evento.
Per utilizzare Schema Registry, devi definire autorizzazioni specifiche per i ruoli IAM per la tua funzione. Vedi [Configurazione completa con ruoli IAM](#sam-property-function-msk-example-complete) per un esempio della configurazione richiesta.
## Sintassi
Per dichiarare questa entità nel tuo AWS SAM modello, usa la seguente sintassi.
### 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
```
## Properties
`BatchSize`
Il numero massimo di registri in ogni batch che Lambda estrae dal flusso o dalla coda e invia alla funzione. Lambda passa tutti i registri del batch alla funzione in una singola chiamata, fino al limite di payload per la chiamata sincrona (6 MB).
*Impostazione predefinita*: 100
*Intervallo valido*: valore minimo di 1. Valore massimo di 10.000.
*Tipo*: integer
*Obbligatorio:* no
*CloudFormation compatibilità*: questa proprietà viene passata direttamente alla `[BatchSize](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html#cfn-lambda-eventsourcemapping-batchsize)` proprietà di una `AWS::Lambda::EventSourceMapping` risorsa.
`BisectBatchOnFunctionError`
Se la funzione restituisce un errore, dividi il batch in due e riprova.
*Tipo*: Booleano
*Obbligatorio:* no
*CloudFormation compatibilità*: questa proprietà viene passata direttamente alla `[BisectBatchOnFunctionError](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html#cfn-lambda-eventsourcemapping-bisectbatchonfunctionerror)` proprietà di una `AWS::Lambda::EventSourceMapping` risorsa.
`ConsumerGroupId`
Una stringa che configura il modo in cui gli eventi verranno letti dagli argomenti di Kafka.
▬*Tipo:* stringa
*Obbligatorio:* no
*CloudFormation compatibilità*: questa proprietà viene passata direttamente alla `[AmazonManagedKafkaConfiguration](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html)` proprietà di una risorsa. `AWS::Lambda::EventSourceMapping`
`DestinationConfig`
Oggetto di configurazione che specifica la destinazione di un evento dopo che Lambda lo elabora.
Utilizza questa proprietà per specificare la destinazione delle chiamate non riuscite dall'origine dell'evento Amazon MSK.
*Tipo:* [DestinationConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html#cfn-lambda-eventsourcemapping-destinationconfig)
*Obbligatorio:* no
*CloudFormation compatibilità*: questa proprietà viene passata direttamente alla `[ DestinationConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-destinationconfig.html)` proprietà di una risorsa. `AWS::Lambda::EventSourceMapping`
`Enabled`
Disabilita la mappatura dell'origine eventi per sospendere il polling e la chiamata.
*Tipo*: Booleano
*Obbligatorio:* no
*CloudFormation compatibilità*: questa proprietà viene passata direttamente alla `[Enabled](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html#cfn-lambda-eventsourcemapping-enabled)` proprietà di una `AWS::Lambda::EventSourceMapping` risorsa.
`FilterCriteria`
Un oggetto che definisce i criteri che determinano se Lambda deve elaborare un evento. Per ulteriori informazioni, consulta il [filtro AWS Lambda degli eventi nella Guida per](https://docs.aws.amazon.com/lambda/latest/dg/invocation-eventfiltering.html) gli *AWS Lambda sviluppatori*.
*Tipo:* [FilterCriteria](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-filtercriteria.html)
*Obbligatorio:* no
*CloudFormation compatibilità*: questa proprietà viene passata direttamente alla `[FilterCriteria](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-filtercriteria.html)` proprietà di una `AWS::Lambda::EventSourceMapping` risorsa.
`FunctionResponseTypes`
Un elenco dei tipi di risposta attualmente applicati alla mappatura delle sorgenti degli eventi. Per ulteriori informazioni, consulta la pagina [Segnalazione di errori degli elementi batch](https://docs.aws.amazon.com/lambda/latest/dg/kafka-retry-configurations.html) nella *Guida per gli sviluppatori di AWS Lambda *.
*Valori validi*: `ReportBatchItemFailures`
Tipo: elenco
*Obbligatorio:* no
*CloudFormation compatibilità*: questa proprietà viene passata direttamente alla `[FunctionResponseTypes](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html#cfn-lambda-eventsourcemapping-functionresponsetypes)` proprietà di una `AWS::Lambda::EventSourceMapping` risorsa.
`KmsKeyArn`
L'Amazon Resource Name (ARN) della chiave per crittografare le informazioni relative a questo evento.
▬*Tipo:* stringa
*Obbligatorio:* no
*CloudFormation compatibilità*: questa proprietà viene passata direttamente alla `[KmsKeyArn](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html#cfn-lambda-eventsourcemapping-kmskeyarn)` proprietà di una `AWS::Lambda::EventSourceMapping` risorsa.
`MaximumBatchingWindowInSeconds`
Il tempo massimo in secondi per la raccolta dei record prima di richiamare la funzione.
*Tipo*: integer
*Obbligatorio:* no
*CloudFormation compatibilità*: questa proprietà viene passata direttamente alla `[MaximumBatchingWindowInSeconds](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html#cfn-lambda-eventsourcemapping-maximumbatchingwindowinseconds)` proprietà di una `AWS::Lambda::EventSourceMapping` risorsa.
`MaximumRecordAgeInSeconds`
L'età massima di un record che Lambda invia a una funzione per l'elaborazione.
*Tipo*: integer
*Obbligatorio:* no
*CloudFormation compatibilità*: questa proprietà viene passata direttamente alla `[MaximumRecordAgeInSeconds](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html#cfn-lambda-eventsourcemapping-maximumrecordageinseconds)` proprietà di una `AWS::Lambda::EventSourceMapping` risorsa.
`MaximumRetryAttempts`
Il numero massimo di ripetizioni consentite quando la funzione restituisce un errore.
*Tipo*: integer
*Obbligatorio:* no
*CloudFormation compatibilità*: questa proprietà viene passata direttamente alla `[MaximumRetryAttempts](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html#cfn-lambda-eventsourcemapping-maximumretryattempts)` proprietà di una `AWS::Lambda::EventSourceMapping` risorsa.
`LoggingConfig`
Un oggetto di configurazione che specifica la configurazione di registrazione per la mappatura dell'origine degli eventi.
*Tipo:* [LoggingConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-loggingconfig.html)
*Obbligatorio:* no
*CloudFormation compatibilità*: questa proprietà viene passata direttamente alla `[LoggingConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-loggingconfig.html)` proprietà di una risorsa. `AWS::Lambda::EventSourceMapping`
`MetricsConfig`
Un oggetto di configurazione che specifica la configurazione delle metriche per la mappatura dell'origine degli eventi.
*Tipo:* [MetricsConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-metricsconfig.html)
*Obbligatorio:* no
*CloudFormation compatibilità*: questa proprietà viene passata direttamente alla `[MetricsConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-metricsconfig.html)` proprietà di una risorsa. `AWS::Lambda::EventSourceMapping`
`ProvisionedPollerConfig`
Configurazione per aumentare la quantità di poller utilizzati per calcolare le mappature delle sorgenti degli eventi. Questa configurazione consente un minimo di 1 poller e un massimo di 2000 poller. Per un esempio, fare riferimento a. [ProvisionedPollerConfig esempio](#sam-property-function-msk-example-provisionedpollerconfig)
*Tipo:* [ProvisionedPollerConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-provisionedpollerconfig)
*Obbligatorio:* no
*CloudFormation compatibilità*: questa proprietà viene passata direttamente alla `[ProvisionedPollerConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-provisionedpollerconfig)` proprietà di una `AWS::Lambda::EventSourceMapping` risorsa.
`SchemaRegistryConfig`
Configurazione per l'utilizzo di un registro degli schemi con l'origine degli eventi Kafka.
Questa funzionalità deve essere `ProvisionedPollerConfig` configurata.
*Tipo*: SchemaRegistryConfig
*Obbligatorio:* no
*CloudFormation compatibilità:* questa proprietà viene passata direttamente alla `[AmazonManagedKafkaEventSourceConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-amazonmanagedkafkaeventsourceconfig)` proprietà di una `AWS::Lambda::EventSourceMapping` risorsa.
`SourceAccessConfigurations`
Un array del protocollo di autenticazione, dei componenti VPC o dell'host virtuale per proteggere e definire l'origine eventi.
*Valori validi*: `CLIENT_CERTIFICATE_TLS_AUTH`
*Tipo*: elenco di [SourceAccessConfiguration](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-lambda-eventsourcemapping-sourceaccessconfiguration.html)
*Obbligatorio:* no
*CloudFormation compatibilità:* questa proprietà fa parte della [AmazonManagedKafkaEventSourceConfig](https://docs.aws.amazon.com/AWSCloudFormation/latest/TemplateReference/aws-properties-lambda-eventsourcemapping-amazonmanagedkafkaeventsourceconfig)proprietà di una risorsa. `AWS::Lambda::EventSourceMapping`
`StartingPosition`
La posizione in un flusso da cui iniziare la lettura.
+ `AT_TIMESTAMP`— Specificare l'ora a partire dalla quale iniziare a leggere i record.
+ `LATEST`— Leggi solo i nuovi record.
+ `TRIM_HORIZON`— Elabora tutti i record disponibili.
*Valori validi*: `AT_TIMESTAMP` \$1 `LATEST` \$1 `TRIM_HORIZON`
▬*Tipo:* stringa
*Obbligatorio:* no
*CloudFormation compatibilità*: questa proprietà viene passata direttamente alla `[StartingPosition](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html#cfn-lambda-eventsourcemapping-startingposition)` proprietà di una `AWS::Lambda::EventSourceMapping` risorsa.
`StartingPositionTimestamp`
L'ora da cui iniziare a leggere, in secondi di tempo Unix. Definisce `StartingPositionTimestamp` quando `StartingPosition` è specificato come`AT_TIMESTAMP`.
*Tipo:* numero a doppia precisione
*Obbligatorio:* no
*CloudFormation compatibilità*: questa proprietà viene passata direttamente alla `[StartingPositionTimestamp](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html#cfn-lambda-eventsourcemapping-startingpositiontimestamp)` proprietà di una `AWS::Lambda::EventSourceMapping` risorsa.
`Stream`
L'Amazon Resource Name (ARN) del flusso di dati o di un consumatore di streaming.
▬*Tipo:* stringa
*Obbligatorio:* sì
*CloudFormation compatibilità*: questa proprietà viene passata direttamente alla `[EventSourceArn](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html#cfn-lambda-eventsourcemapping-eventsourcearn)` proprietà di una `AWS::Lambda::EventSourceMapping` risorsa.
`Topics`
Il nome dell'argomento Kafka.
Tipo: elenco
*Obbligatorio:* sì
*CloudFormation compatibilità*: questa proprietà viene passata direttamente alla `[Topics](https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-lambda-eventsourcemapping.html#cfn-lambda-eventsourcemapping-topics)` proprietà di una `AWS::Lambda::EventSourceMapping` risorsa.
## Esempi
### Configurazione completa con ruoli IAM
L'esempio seguente mostra una configurazione completa che include la configurazione del ruolo IAM richiesta per l'utilizzo di 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 esempio
```
ProvisionedPollerConfig:
MinimumPollers: 1
MaximumPollers: 200
```
### Esempio di Amazon MSK per un cluster esistente
Di seguito è riportato un esempio di un tipo di origine di `MSK` eventi per un cluster Amazon MSK che esiste già in un Account 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
```
### Esempio di Amazon MSK per un cluster dichiarato nello stesso modello
Di seguito è riportato un esempio di un tipo di origine di `MSK` eventi per un cluster Amazon MSK dichiarato nello stesso file modello.
#### 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
```
#### Fonte di eventi MSK con registro dello schema
Di seguito è riportato un esempio di un tipo di origine di `MSK` eventi configurato con un registro dello schema.
```
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
```
#### Fonte di eventi MSK con registro degli schemi Confluent
Di seguito è riportato un esempio di un tipo di origine di `MSK` eventi configurato con un 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
```