KafkaTrigger Interface

Paquet:

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); }

Résumé de la méthode

Modificateur et type	Méthode et description
BrokerAuthenticationMode	authenticationMode() Mécanisme SASL à utiliser pour l’authentification. Valeurs autorisées : Gssapi, Plain, ScramSha256, ScramSha512 Par défaut : PLAIN
String	brokerList() Définit brokerList.
Cardinality	cardinality() Cardinalité de l’entrée du déclencheur. Choisissez « Un » si l’entrée est un seul message ou « Plusieurs » si l’entrée est un tableau de messages. Si vous choisissez « Plusieurs », définissez un dataType. Valeur par défaut : 'One'
String	consumerGroup() Définit le groupe de consommateurs.
String	dataType() Définit comment le runtime Functions doit traiter la valeur de paramètre. Les valeurs possibles sont les suivantes : <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() Définit la chaîne de connexion EventHub lors de l’utilisation de la fonctionnalité d’en-tête de protocole KafkaOutput d’Azure EventHubs.
String	name() Nom de variable utilisé dans le code de la fonction pour la requête ou le corps de la requête.
String	password() Mot de passe SASL avec plain et SASL-SCRAM-.. mécanismes Par défaut : «  » security.protocol dans librdkafka
BrokerProtocol	protocol() Définit le protocole de sécurité utilisé pour communiquer avec les répartiteurs par défaut est PLAINTEXT
String	sslCaLocation() Chemin d’accès au fichier de certificat d’autorité de certification pour la vérification du certificat du répartiteur. ssl.ca.location in librdkafka
String	sslCertificateLocation() Chemin d’accès au certificat du client. ssl.certificate.location dans librdkafka
String	sslKeyLocation() Chemin d’accès à la clé privée du client (PEM) utilisée pour l’authentification. Par défaut « » ssl.key.location dans librdkafka
String	sslKeyPassword() Mot de passe pour le certificat du client. ssl.key.password dans librdkafka
String	topic() Définit la rubrique .
String	username() Nom d’utilisateur SASL avec plain et SASL-SCRAM-.. mécanismes Par défaut : «  »

Détails de la méthode

authenticationMode

public BrokerAuthenticationMode authenticationMode() default BrokerAuthenticationMode.NOTSET

Mécanisme SASL à utiliser pour l’authentification. Valeurs autorisées : Gssapi, Plain, ScramSha256, ScramSha512 Par défaut : PLAIN

Returns:

Mode d’authentification du répartiteur.

brokerList

public String brokerList()

Définit brokerList.

Returns:

BrokerList.

cardinality

public Cardinality cardinality() default Cardinality.ONE

Cardinalité de l’entrée du déclencheur. Choisissez « Un » si l’entrée est un seul message ou « Plusieurs » si l’entrée est un tableau de messages. Si vous choisissez « Plusieurs », définissez un dataType. Valeur par défaut : 'One'

Returns:

Cardinalité.

consumerGroup

public String consumerGroup()

Définit le groupe de consommateurs.

Returns:

Groupe de consommateurs.

dataType

public String dataType() default ""

Définit comment le runtime Functions doit traiter la valeur de paramètre. Les valeurs possibles sont les suivantes :

<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 qui sera utilisé par le runtime Functions.

eventHubConnectionString

public String eventHubConnectionString() default ""

Définit la chaîne de connexion EventHub lors de l’utilisation de la fonctionnalité d’en-tête de protocole KafkaOutput d’Azure EventHubs.

Returns:

Chaîne de connexion EventHub.

name

public String name()

Nom de variable utilisé dans le code de la fonction pour la requête ou le corps de la requête.

Returns:

Nom de variable utilisé dans le code de la fonction pour la requête ou le corps de la requête.

password

public String password() default ""

Mot de passe SASL avec plain et SASL-SCRAM-.. mécanismes Par défaut : «  »

security.protocol dans librdkafka

Returns:

Mot de passe SASL.

protocol

public BrokerProtocol protocol() default BrokerProtocol.NOTSET

Définit le protocole de sécurité utilisé pour communiquer avec les répartiteurs par défaut est PLAINTEXT

Returns:

Protocole de sécurité.

sslCaLocation

public String sslCaLocation() default ""

Chemin d’accès au fichier de certificat d’autorité de certification pour la vérification du certificat du répartiteur. ssl.ca.location in librdkafka

Returns:

Chemin d’accès au fichier de certificat d’autorité de certification.

sslCertificateLocation

public String sslCertificateLocation() default ""

Chemin d’accès au certificat du client. ssl.certificate.location dans librdkafka

Returns:

Emplacement du certificat ssl.

sslKeyLocation

public String sslKeyLocation() default ""

Chemin d’accès à la clé privée du client (PEM) utilisée pour l’authentification. Par défaut « » ssl.key.location dans librdkafka

Returns:

Emplacement de la clé ssl.

sslKeyPassword

public String sslKeyPassword() default ""

Mot de passe pour le certificat du client. ssl.key.password dans librdkafka

Returns:

Mot de passe de la clé ssl.

topic

public String topic()

Définit la rubrique .

Returns:

Rubrique.

username

public String username() default ""

Nom d’utilisateur SASL avec plain et SASL-SCRAM-.. mécanismes Par défaut : «  »

Returns:

Nom d’utilisateur SASL.