SelfManagedKafka

L'oggetto che descrive un tipo di origineSelfManagedKafka dell'evento. Per ulteriori informazioni, consulta UtilizzoAWS Lambda con Apache Kafka autogestito nella Guida per gliAWS Lambda sviluppatori.

AWS Serverless Application Model(AWS SAM) genera una AWS::Lambda::EventSourceMappingrisorsa quando questo tipo di evento è impostato.

Sintassi

Per dichiarare questa entità nelAWS SAM modello, utilizzare la sintassi seguente.

YAML

  BatchSize: Integer
  ConsumerGroupId: String
  Enabled: Boolean
  FilterCriteria: FilterCriteria
  KafkaBootstrapServers: List
  SourceAccessConfigurations: SourceAccessConfiguration
  Topics: List

Proprietà

BatchSize

Il numero massimo di registri in ogni batch che Lambda estrae dal flusso e invia alla funzione.

Type: Numero intero

Richiesto: No

Default: 100

AWS CloudFormationcompatibilità: Questa proprietà viene passata direttamente allaBatchSize proprietà di unaAWS::Lambda::EventSourceMapping risorsa.

Minimum: 1

Maximum: 10000

ConsumerGroupId

Una stringa che configura il modo in cui gli eventi verranno letti dagli argomenti di Kafka.

Type: Stringa

Richiesto: No

AWS CloudFormationcompatibilità: Questa proprietà viene passata direttamente allaSelfManagedKafkaConfiguration proprietà di unaAWS::Lambda::EventSourceMapping risorsa.

Enabled

Disabilita la mappatura dell'origine eventi per sospendere il polling e la chiamata.

Type: Boolean

Richiesto: No

AWS CloudFormationcompatibilità: Questa proprietà viene passata direttamente allaEnabled proprietà di unaAWS::Lambda::EventSourceMapping risorsa.

FilterCriteria

Un oggetto che definisce i criteri per determinare se Lambda debba elaborare un evento. Per ulteriori informazioni, consulta il filtraggioAWS Lambda degli eventi nella Guida perAWS Lambda gli sviluppatori.

Tipo: FilterCriteria

Richiesto: No

AWS CloudFormationcompatibilità: Questa proprietà viene passata direttamente allaFilterCriteria proprietà di unaAWS::Lambda::EventSourceMapping risorsa.

KafkaBootstrapServers

L'elenco dei server bootstrap per i broker Kafka. Includi la porta, ad esempiobroker.example.com:xxxx

Type: Elenco

Richiesto: No

AWS CloudFormationcompatibilità: Questa proprietà è unicaAWS SAM e non ha unAWS CloudFormation equivalente.

SourceAccessConfigurations

Un array del protocollo di autenticazione, dei componenti VPC o dell'host virtuale per proteggere e definire l'origine eventi.

Tipo: SourceAccessConfiguration

Richiesto: Sì

AWS CloudFormationcompatibilità: Questa proprietà viene passata direttamente allaSourceAccessConfigurations proprietà di unaAWS::Lambda::EventSourceMapping risorsa.

Topics

Il nome dell'argomento Kafka.

Type: Elenco

Richiesto: Sì

AWS CloudFormationcompatibilità: Questa proprietà viene passata direttamente allaTopics proprietà di unaAWS::Lambda::EventSourceMapping risorsa.

Examples (Esempi)

Origine eventi Kafka gestito dal cliente

Di seguito è illustrato un esempio di un tipo di origineSelfManagedKafka evento.

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