KafkaTrigger Interfaz

Paquete:

com.microsoft.azure.functions.annotation

public interface KafkaTrigger

KafkaTrigger(name = "kafkaTrigger", topic = "users", brokerList="broker:29092", consumerGroup="functions") List<Map<String, String>> kafkaEventData, final ExecutionContext context ) { context.getLogger().info(kafkaEventData); }

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. Valores permitidos: Gssapi, Plain, ScramSha256, ScramSha512 Default: PLAIN
String	brokerList() Define BrokerList.
Cardinality	cardinality() Cardinalidad de la entrada del desencadenador. Elija "Uno" si la entrada es un único mensaje o "Muchos" si la entrada es una matriz de mensajes. Si elige "Muchos", establezca un dataType. Valor predeterminado: "Uno"
String	consumerGroup() Define el grupo de consumidores.
String	dataType() Define cómo debe tratar Functions Runtime el valor del parámetro. Los valores posibles son: <li> <p>"": get the value as a string, and try to deserialize to actual parameter type like POJO </p> </li> <li> <p>string: always get the value as a string </p> </li> <li> <p>binary: get the value as a binary data, and try to deserialize to actual parameter type byte[] </p> </li>
String	eventHubConnectionString() Define la cadena de conexión de EventHub cuando se usa la característica de encabezado del protocolo KafkaOutput de Azure EventHubs.
String	name() El nombre de variable que se usa en el código de función para la solicitud o el cuerpo de la solicitud.
String	password() Contraseña SASL con PLAIN y SASL-SCRAM-.. mecanismos predeterminados: "" security.protocol en librdkafka
BrokerProtocol	protocol() Define el protocolo de seguridad que se usa para comunicarse con agentes predeterminado es PLAINTEXT.
String	sslCaLocation() Ruta de acceso al archivo de certificado de CA 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. Valores permitidos: Gssapi, Plain, ScramSha256, ScramSha512 Default: PLAIN

Returns:

Modo de autenticación del agente.

brokerList

public String brokerList()

Define BrokerList.

Returns:

BrokerList.

cardinality

public Cardinality cardinality() default Cardinality.ONE

Cardinalidad de la entrada del desencadenador. Elija "Uno" si la entrada es un único mensaje o "Muchos" si la entrada es una matriz de mensajes. Si elige "Muchos", establezca un dataType. Valor predeterminado: "Uno"

Returns:

Cardinalidad.

consumerGroup

public String consumerGroup()

Define el grupo de consumidores.

Returns:

El grupo de consumidores.

dataType

public String dataType() default ""

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

<li>

  <p>"": get the value as a string, and try to deserialize to actual parameter type like POJO </p>

</li>

<li>

  <p>string: always get the value as a string </p>

</li>

<li>

  <p>binary: get the value as a binary data, and try to deserialize to actual parameter type byte[] </p>

</li>

Returns:

DataType que usará el runtime de Functions.

eventHubConnectionString

public String eventHubConnectionString() default ""

Define la cadena de conexión de EventHub cuando se usa la característica de encabezado del protocolo KafkaOutput de Azure EventHubs.

Returns:

Cadena de conexión de EventHub.

name

public String name()

El nombre de variable que se usa en el código de función para la solicitud o el cuerpo de la solicitud.

Returns:

El nombre de variable que se usa en el código de función para la solicitud o el cuerpo de la solicitud.

password

public String password() default ""

Contraseña SASL con PLAIN y SASL-SCRAM-.. mecanismos predeterminados: ""

security.protocol en librdkafka

Returns:

Contraseña de SASL.

protocol

public BrokerProtocol protocol() default BrokerProtocol.NOTSET

Define el protocolo de seguridad que se usa para comunicarse con agentes predeterminado es PLAINTEXT.

Returns:

Protocolo de seguridad.

sslCaLocation

public String sslCaLocation() default ""

Ruta de acceso al archivo de certificado de CA para comprobar el certificado del agente. ssl.ca.location en librdkafka

Returns:

Ruta de acceso al archivo de certificado de CA.

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:

El tema.

username

public String username() default ""

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

Returns:

Nombre de usuario de SASL.