SelfManagedKafka

El objeto que describe unSelfManagedKafkatipo de origen de evento. Para obtener más información, consulteUso deAWS Lambdacon Apache Kafka autoadministradoen laAWS LambdaGuía para desarrolladores.

AWS SAMgenera unAWS::Lambda::EventSourceMappingrecurso cuando se establece este tipo de evento.

Sintaxis

Para declarar esta entidad en suAWS Serverless Application Model(AWS SAM), utilice la siguiente sintaxis.

YAML

  BatchSize: Integer
  Enabled: Boolean
  KafkaBootstrapServers: List
  SourceAccessConfigurations: SourceAccessConfiguration
  Topics: List

Properties

BatchSize

El número máximo de registros en cada lote que Lambda extrae del flujo y envía a su función.

Type: Entero

Obligatorio: No

Valor predeterminado: 100

AWS CloudFormationcompatibilidad: Esta propiedad se transfiere directamente alBatchSizepropiedad de unAWS::Lambda::EventSourceMappingrecurso.

Minimum: 1

Maximum: 10000

Enabled

Deshabilita el mapeo de origen de eventos para pausar el sondeo y la invocación.

Type: Booleano

Obligatorio: No

AWS CloudFormationcompatibilidad: Esta propiedad se transfiere directamente alEnabledpropiedad de unAWS::Lambda::EventSourceMappingrecurso.

KafkaBootstrapServers

La lista de servidores de arranque para sus agentes Kafka. Incluya el puerto, por ejemplobroker.example.com:xxxx

Type: Lista

Obligatorio: No

AWS CloudFormationcompatibilidad: Esta propiedad es específica deAWS SAMy no tieneAWS CloudFormationequivalente.

SourceAccessConfigurations

Una matriz del protocolo de autenticación, los componentes de VPC o el anfitrión virtual para proteger y definir su fuente de eventos.

Type: SourceAccessConfiguration

Obligatorio: Sí

AWS CloudFormationcompatibilidad: Esta propiedad se transfiere directamente alSourceAccessConfigurationspropiedad de unAWS::Lambda::EventSourceMappingrecurso.

Topics

El nombre del tema de Kafka.

Type: Lista

Obligatorio: Sí

AWS CloudFormationcompatibilidad: Esta propiedad se transfiere directamente alTopicspropiedad de unAWS::Lambda::EventSourceMappingrecurso.

Ejemplos

Fuente de eventos Kafka autoadministrado

A continuación se muestra un ejemplo deSelfManagedKafkatipo de origen de 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