KafkaTrigger Schnittstelle

Paket:

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

Methodenzusammenfassung

Modifizierer und Typ	Methode und Beschreibung
BrokerAuthenticationMode	authenticationMode() SASL-Mechanismus, der für die Authentifizierung verwendet werden soll. Zulässige Werte: Gssapi, Plain, ScramSha256, ScramSha512 Default: PLAIN
String	brokerList() Definiert die BrokerList.
Cardinality	cardinality() Kardinalität der Triggereingabe. Wählen Sie "One" aus, wenn die Eingabe eine einzelne Nachricht ist, oder "Viele", wenn die Eingabe ein Array von Nachrichten ist. Wenn Sie "Viele" auswählen, legen Sie einen Datentyp fest. Standardeinstellung: "One"
String	consumerGroup() Definiert die Consumergruppe.
String	dataType() Definiert, wie die Functions-Runtime den Parameterwert behandeln soll. Mögliche Werte: <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() Definiert die EventHub-Verbindungszeichenfolge bei Verwendung der KafkaOutput-Protokollheaderfunktion von Azure EventHubs.
String	name() Der Variablenname, der im Funktionscode für die Anforderung oder den Anforderungstext verwendet wird.
String	password() SASL-Kennwort mit PLAIN und SASL-SCRAM-.. mechanisms Default: "" security.protocol in librdkafka
BrokerProtocol	protocol() Definiert das Sicherheitsprotokoll, das für die Kommunikation mit Brokern verwendet wird, standardmäßig PLAINTEXT.
String	sslCaLocation() Pfad zur Zertifizierungsstellenzertifikatdatei zum Überprüfen des Brokerzertifikats. ssl.ca.location in librdkafka
String	sslCertificateLocation() Pfad zum Clientzertifikat. ssl.certificate.location in librdkafka
String	sslKeyLocation() Pfad zum privaten Schlüssel (PEM) des Clients, der für die Authentifizierung verwendet wird. Standard "" ssl.key.location in librdkafka
String	sslKeyPassword() Kennwort für das Zertifikat des Clients. ssl.key.password in librdkafka
String	topic() Definiert das Thema.
String	username() SASL-Benutzername mit plain und SASL-SCRAM-.. Mechanismen Standard: ""

Details zur Methode

authenticationMode

public BrokerAuthenticationMode authenticationMode() default BrokerAuthenticationMode.NOTSET

SASL-Mechanismus, der für die Authentifizierung verwendet werden soll. Zulässige Werte: Gssapi, Plain, ScramSha256, ScramSha512 Default: PLAIN

Gibt zurück:

Der Brokerauthentifizierungsmodus.

brokerList

public String brokerList()

Definiert die BrokerList.

Gibt zurück:

Die brokerList.

cardinality

public Cardinality cardinality() default Cardinality.ONE

Kardinalität der Triggereingabe. Wählen Sie "One" aus, wenn die Eingabe eine einzelne Nachricht ist, oder "Viele", wenn die Eingabe ein Array von Nachrichten ist. Wenn Sie "Viele" auswählen, legen Sie einen Datentyp fest. Standardeinstellung: "One"

Gibt zurück:

Die Kardinalität.

consumerGroup

public String consumerGroup()

Definiert die Consumergruppe.

Gibt zurück:

Die Consumergruppe.

dataType

public String dataType() default ""

Definiert, wie die Functions-Runtime den Parameterwert behandeln soll. Mögliche Werte:

<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>

Gibt zurück:

Der dataType, der von der Functions-Runtime verwendet wird.

eventHubConnectionString

public String eventHubConnectionString() default ""

Definiert die EventHub-Verbindungszeichenfolge bei Verwendung der KafkaOutput-Protokollheaderfunktion von Azure EventHubs.

Gibt zurück:

Die EventHub-Verbindungszeichenfolge.

name

public String name()

Der Variablenname, der im Funktionscode für die Anforderung oder den Anforderungstext verwendet wird.

Gibt zurück:

Der Variablenname, der im Funktionscode für die Anforderung oder den Anforderungstext verwendet wird.

password

public String password() default ""

SASL-Kennwort mit PLAIN und SASL-SCRAM-.. mechanisms Default: ""

security.protocol in librdkafka

Gibt zurück:

Das SASL-Kennwort.

protocol

public BrokerProtocol protocol() default BrokerProtocol.NOTSET

Definiert das Sicherheitsprotokoll, das für die Kommunikation mit Brokern verwendet wird, standardmäßig PLAINTEXT.

Gibt zurück:

Das Sicherheitsprotokoll.

sslCaLocation

public String sslCaLocation() default ""

Pfad zur Zertifizierungsstellenzertifikatdatei zum Überprüfen des Brokerzertifikats. ssl.ca.location in librdkafka

Gibt zurück:

Der Pfad zur Zertifizierungsstellenzertifikatdatei.

sslCertificateLocation

public String sslCertificateLocation() default ""

Pfad zum Clientzertifikat. ssl.certificate.location in librdkafka

Gibt zurück:

Der Speicherort des SSL-Zertifikats.

sslKeyLocation

public String sslKeyLocation() default ""

Pfad zum privaten Schlüssel (PEM) des Clients, der für die Authentifizierung verwendet wird. Standard "" ssl.key.location in librdkafka

Gibt zurück:

Der Speicherort des SSL-Schlüssels.

sslKeyPassword

public String sslKeyPassword() default ""

Kennwort für das Zertifikat des Clients. ssl.key.password in librdkafka

Gibt zurück:

Das Ssl-Schlüsselkennwort.

topic

public String topic()

Definiert das Thema.

Gibt zurück:

Das Thema.

username

public String username() default ""

SASL-Benutzername mit plain und SASL-SCRAM-.. Mechanismen Standard: ""

Gibt zurück:

Der SASL-Benutzername.