Compartir a través de

KafkaOutput Interfaz

  • Referencia
Paquete:
com.microsoft.azure.functions.annotation

public interface KafkaOutput

KafkaOutput(name = "event", topic = "users", brokerList="broker:29092") OutputBinding<String<output, final ExecutionContext context) { context.getLogger().info("Message:" + message); output.setValue(message); return "{ \"id": "" + System.currentTimeMillis() + "", "description": "" + message + "" }"; }

Resumen del método

Modificador y tipo Método y descripción
BrokerAuthenticationMode authenticationMode()

Mecanismo SASL que se va a usar para la autenticación. Valor predeterminado: PLAIN
int batchSize()

Define el número máximo de mensajes por lotes en un objeto MessageSet. valor predeterminado: 10000
String brokerList()

Define BrokerList.
String dataType()

Define cómo debe tratar Functions Runtime el valor del parámetro. Los valores posibles son:

    <li>

  <p>"" or string: treat it as a string whose value is serialized from the parameter </p>

</li>

<li>

  <p>binary: treat it as a binary data whose value comes from for example OutputBinding&lt;byte[]&lt;</p>

</li>

boolean enableIdempotence()

Cuando se establece en "true", el productor garantizará que los mensajes se produzcan correctamente una vez y en el orden de producción original. valor predeterminado: false
int maxMessageBytes()

Define el tamaño máximo del mensaje de transmisión. Valor predeterminado: 1 MB
int maxRetries()

Cuántas veces se reintenta el envío de un mensaje con errores. **Nota:** valor predeterminado: 2 El reintento puede provocar el reordenamiento a menos que EnableIdempotence esté establecido en true.

int messageTimeoutMs()

Tiempo de espera del mensaje local. Este valor solo se aplica localmente y limita el tiempo que espera un mensaje generado para la entrega correcta. Un tiempo de 0 es infinito. Este valor es el tiempo máximo que se usa para entregar un mensaje (incluidos los reintentos). El error de entrega se produce cuando se supera el número de reintentos o el tiempo de espera del mensaje. valor predeterminado: 300000
String name()

Nombre de variable usado en function.json.
String password()

Contraseña SASL con PLAIN y SASL-SCRAM-.. mecanismos El valor predeterminado es texto no cifrado

security.protocol en librdkafka
BrokerProtocol protocol()

Obtiene o establece el protocolo de seguridad usado para comunicarse con los agentes predeterminado es PLAINTEXT.
int requestTimeoutMs()

Tiempo de espera de espera de la solicitud de productor en milisegundos. valor predeterminado: 5000
String sslCaLocation()

Ruta de acceso al archivo de certificado de ENTIDAD de certificación para comprobar el certificado del agente. ssl.ca.location en librdkafka
String sslCertificateLocation()

Ruta de acceso al certificado del cliente. ssl.certificate.location en librdkafka
String sslKeyLocation()

Ruta de acceso a la clave privada (PEM) del cliente que se usa para la autenticación. Valor predeterminado "" ssl.key.location en librdkafka
String sslKeyPassword()

Contraseña del certificado del cliente. ssl.key.password en librdkafka
String topic()

Define el tema.
String username()

Nombre de usuario de SASL con PLAIN y SASL-SCRAM-.. mecanismos predeterminados: ""

Detalles del método

authenticationMode

public BrokerAuthenticationMode authenticationMode() default BrokerAuthenticationMode.NOTSET

Mecanismo SASL que se va a usar para la autenticación. Valor predeterminado: PLAIN

Returns:

Mecanismo SASL.

batchSize

public int batchSize() default 10000

Define el número máximo de mensajes por lotes en un objeto MessageSet. valor predeterminado: 10000

Returns:

Número máximo de mensajes por lotes en un messageSet.

brokerList

public String brokerList()

Define BrokerList.

Returns:

Cadena de nombre brokerList.

dataType

public String dataType() default ""

Define cómo debe tratar Functions Runtime el valor del parámetro. Los valores posibles son:

    <li>

  <p>"" or string: treat it as a string whose value is serialized from the parameter </p>

</li>

<li>

  <p>binary: treat it as a binary data whose value comes from for example OutputBinding&lt;byte[]&lt;</p>

</li>

Returns:

DataType que usará el entorno de ejecución de Functions.

enableIdempotence

public boolean enableIdempotence() default false

Cuando se establece en "true", el productor garantizará que los mensajes se produzcan correctamente una vez y en el orden de producción original. valor predeterminado: false

Returns:

si la idempotencia está habilitada.

maxMessageBytes

public int maxMessageBytes() default 1000012

Define el tamaño máximo del mensaje de transmisión. Valor predeterminado: 1 MB

Returns:

Tamaño máximo del mensaje de trnasmit.

maxRetries

public int maxRetries() default 2

Cuántas veces se reintenta el envío de un mensaje con errores. **Nota:** valor predeterminado: 2 El reintento puede provocar el reordenamiento a menos que EnableIdempotence esté establecido en true.

Returns:

Número de reintentos máximos.

messageTimeoutMs

public int messageTimeoutMs() default 300000

Tiempo de espera del mensaje local. Este valor solo se aplica localmente y limita el tiempo que espera un mensaje generado para la entrega correcta. Un tiempo de 0 es infinito. Este valor es el tiempo máximo que se usa para entregar un mensaje (incluidos los reintentos). El error de entrega se produce cuando se supera el número de reintentos o el tiempo de espera del mensaje. valor predeterminado: 300000

Returns:

Tiempo de espera del mensaje local.

name

public String name()

Nombre de variable usado en function.json.

Returns:

Nombre de variable usado en function.json.

password

public String password() default ""

Contraseña SASL con PLAIN y SASL-SCRAM-.. mecanismos El valor predeterminado es texto no cifrado

security.protocol en librdkafka

Returns:

Contraseña de SASL.

protocol

public BrokerProtocol protocol() default BrokerProtocol.NOTSET

Obtiene o establece el protocolo de seguridad usado para comunicarse con los agentes predeterminado es PLAINTEXT.

Returns:

Protocolo.

requestTimeoutMs

public int requestTimeoutMs() default 5000

Tiempo de espera de espera de la solicitud de productor en milisegundos. valor predeterminado: 5000

Returns:

Tiempo de espera de espera de la solicitud de productor en milisegundos.

sslCaLocation

public String sslCaLocation() default ""

Ruta de acceso al archivo de certificado de ENTIDAD de certificación para comprobar el certificado del agente. ssl.ca.location en librdkafka

Returns:

La ubicación de la ca ssl.

sslCertificateLocation

public String sslCertificateLocation() default ""

Ruta de acceso al certificado del cliente. ssl.certificate.location en librdkafka

Returns:

Ubicación del certificado ssl.

sslKeyLocation

public String sslKeyLocation() default ""

Ruta de acceso a la clave privada (PEM) del cliente que se usa para la autenticación. Valor predeterminado "" ssl.key.location en librdkafka

Returns:

Ubicación de la clave ssl.

sslKeyPassword

public String sslKeyPassword() default ""

Contraseña del certificado del cliente. ssl.key.password en librdkafka

Returns:

Contraseña de clave ssl.

topic

public String topic()

Define el tema.

Returns:

Nombre del tema.

username

public String username() default ""

Nombre de usuario de SASL con PLAIN y SASL-SCRAM-.. mecanismos predeterminados: ""

Returns:

Nombre de usuario de SASL.

Se aplica a