Compartir vía

Información general de los enlaces de Apache Kafka para Azure Functions

La extensión de Kafka para Azure Functions permite escribir valores en temas de Apache Kafka mediante un enlace de salida. También puede usar un desencadenador para invocar las funciones en respuesta a los mensajes de los temas de Kafka.

Importante

Los enlaces de Kafka solo están disponibles para las instancias de Functions del plan elástico prémium y del plan dedicado (App Service). Solo se admiten en la versión 3.x y posteriores del entorno de ejecución de Functions.

Acción Tipo
Ejecute una función basada en un nuevo evento de Kafka. Desencadenador
Escriba en la secuencia de eventos de Kafka. Enlace de salida

Instalación de la extensión

El paquete NuGet de la extensión que instale depende del modo de C# que esté usando en la aplicación de funciones:

Las funciones se ejecutan en un proceso de trabajo de C# aislado. Para más información, consulte Guía para ejecutar C# Azure Functions en un proceso de trabajo aislado.

Para agregar la extensión al proyecto, instale este paquete NuGet.

Instalación del conjunto

Para poder usar esta extensión de enlace en la aplicación, asegúrese de que el archivo host.json en la raíz del proyecto contiene esta extensionBundle referencia:

{
    "version": "2.0",
    "extensionBundle": {
        "id": "Microsoft.Azure.Functions.ExtensionBundle",
        "version": "[4.0.0, 5.0.0)"
    }
}

En este ejemplo, el version valor de [4.0.0, 5.0.0) indica al host de Functions que use una versión de agrupación que sea al menos 4.0.0 pero menor 5.0.0que , que incluye todas las versiones potenciales de 4.x. Esta notación mantiene eficazmente la aplicación en la versión secundaria más reciente disponible del paquete de extensiones v4.x.

Cuando sea posible, debe usar la versión principal del paquete de extensiones más reciente y permitir que el tiempo de ejecución mantenga automáticamente la versión secundaria más reciente. Puede ver el contenido de la agrupación más reciente en la página de versión de paquetes de extensiones. Para más información, consulte Paquetes de extensiones de Azure Functions.

Habilitación del escalado de entorno de ejecución

Para permitir que las funciones se escalen correctamente en el plan Premium al usar desencadenadores y enlaces de Kafka, debe habilitar la supervisión del escalado del entorno de ejecución.

  1. En Azure Portal, en la aplicación de funciones, seleccione Configuración.

  2. En la pestaña Configuración del entorno de ejecución de la función, en Supervisión de escalado en tiempo de ejecución, seleccione Activado.

    Captura de pantalla del área de Azure Portal para habilitar el escalado en tiempo de ejecución.

configuración de host.json

En esta sección se describen las opciones de configuración disponibles para este enlace en las versiones 3.x y posteriores. La configuración del archivo host.json se aplica a todas las funciones de una instancia de la aplicación de funciones. Para más información sobre la configuración de la aplicación de funciones en las versiones 3.x y posteriores, consulte la referencia de host.json para Azure Functions.

{
    "version": "2.0",
    "extensions": {
        "kafka": {
            "maxBatchSize": 64,
            "SubscriberIntervalInSeconds": 1,
            "ExecutorChannelCapacity": 1,
            "ChannelFullRetryIntervalInMs": 50
        }
    }
}
Propiedad Valor predeterminado Tipo Descripción
ChannelFullRetryIntervalInMs 50 Desencadenador Define el intervalo de reintento del suscriptor, en milisegundos, que se usa al intentar agregar elementos a un canal de capacidad.
ExecutorChannelCapacity 1 Ambos Define la capacidad del mensaje del canal. Una vez alcanzada la capacidad, el suscriptor de Kafka se detiene hasta que la función se pone al día.
MaxBatchSize 64 Desencadenador Tamaño máximo de lote al llamar a una función desencadenada por Kafka.
SubscriberIntervalInSeconds 1 Desencadenador Define la frecuencia mínima con la que se ejecutan los mensajes entrantes, por función en segundos. Solo cuando el volumen del mensaje es menor que MaxBatchSize / SubscriberIntervalInSeconds.

Las siguientes propiedades, que se heredan de la biblioteca cliente de C/C++ de Apache Kafka, también se admiten en la sección kafka de host.json, para desencadenadores o enlaces de salida y desencadenadores:

Propiedad Se aplica a Equivalente a librdkafka
AutoCommitIntervalMs Desencadenador auto.commit.interval.ms
AutoOffsetReset Desencadenador auto.offset.reset
FetchMaxBytes Desencadenador fetch.max.bytes
LibkafkaDebug Ambos debug
MaxPartitionFetchBytes Desencadenador max.partition.fetch.bytes
MaxPollIntervalMs Desencadenador max.poll.interval.ms
MetadataMaxAgeMs Ambos metadata.max.age.ms
QueuedMinMessages Desencadenador queued.min.messages
QueuedMaxMessagesKbytes Desencadenador queued.max.messages.kbytes
ReconnectBackoffMs Desencadenador reconnect.backoff.max.ms
ReconnectBackoffMaxMs Desencadenador reconnect.backoff.max.ms
SessionTimeoutMs Desencadenador session.timeout.ms
SocketKeepaliveEnable Ambos socket.keepalive.enable
StatisticsIntervalMs Desencadenador statistics.interval.ms

Pasos siguientes

  • Last updated on