次の方法で共有

KafkaTrigger インターフェイス

  • リファレンス
パッケージ:
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); }

メソッドの概要

修飾子と型 メソッドと説明
BrokerAuthenticationMode authenticationMode()

認証に使用する SASL メカニズム。 使用できる値: Gssapi、Plain、ScramSha256、ScramSha512 既定値: PLAIN
String brokerList()

BrokerList を定義します。
Cardinality cardinality()

トリガー入力のカーディナリティ。 入力が 1 つのメッセージの場合は "One" を選択し、入力がメッセージの配列の場合は "多" を選択します。 [多] を選択した場合は、dataType を設定してください。 既定値: 'One'
String consumerGroup()

コンシューマー グループを定義します。
String dataType()

Functions ランタイムがパラメーター値をどのように扱うかを定義します。 次のいずれかの値になります。

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

Azure EventHubs の KafkaOutput プロトコル ヘッダー機能を使用する場合の EventHub 接続文字列を定義します。
String name()

要求または要求本文の関数コードで使用される変数名。
String password()

PLAIN と SASL-SCRAM を使用した SASL パスワード-.. メカニズム 既定: ""

librdkafka の security.protocol
BrokerProtocol protocol()

ブローカーとの通信に使用されるセキュリティ プロトコルを定義します。既定値は PLAINTEXT です
String sslCaLocation()

ブローカーの証明書を確認するための CA 証明書ファイルへのパス。 librdkafka の ssl.ca.location
String sslCertificateLocation()

クライアントの証明書へのパス。 librdkafka 内の ssl.certificate.location
String sslKeyLocation()

認証に使用されるクライアントの秘密キー (PEM) へのパス。 librdkafka の既定の "" ssl.key.location
String sslKeyPassword()

クライアントの証明書のパスワード。 librdkafka の ssl.key.password
String topic()

トピックを定義します。
String username()

PLAIN と SASL-SCRAM を使用した SASL ユーザー名-.. メカニズム 既定: ""

メソッドの詳細

authenticationMode

public BrokerAuthenticationMode authenticationMode() default BrokerAuthenticationMode.NOTSET

認証に使用する SASL メカニズム。 使用できる値: Gssapi、Plain、ScramSha256、ScramSha512 既定値: PLAIN

Returns:

ブローカー認証モード。

brokerList

public String brokerList()

BrokerList を定義します。

Returns:

brokerList。

cardinality

public Cardinality cardinality() default Cardinality.ONE

トリガー入力のカーディナリティ。 入力が 1 つのメッセージの場合は "One" を選択し、入力がメッセージの配列の場合は "多" を選択します。 [多] を選択した場合は、dataType を設定してください。 既定値: 'One'

Returns:

カーディナリティ。

consumerGroup

public String consumerGroup()

コンシューマー グループを定義します。

Returns:

コンシューマー グループ。

dataType

public String dataType() default ""

Functions ランタイムがパラメーター値をどのように扱うかを定義します。 次のいずれかの値になります。

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

Functions ランタイムによって使用される dataType。

eventHubConnectionString

public String eventHubConnectionString() default ""

Azure EventHubs の KafkaOutput プロトコル ヘッダー機能を使用する場合の EventHub 接続文字列を定義します。

Returns:

EventHub 接続文字列。

name

public String name()

要求または要求本文の関数コードで使用される変数名。

Returns:

要求または要求本文の関数コードで使用される変数名。

password

public String password() default ""

PLAIN と SASL-SCRAM を使用した SASL パスワード-.. メカニズム 既定: ""

librdkafka の security.protocol

Returns:

SASL パスワード。

protocol

public BrokerProtocol protocol() default BrokerProtocol.NOTSET

ブローカーとの通信に使用されるセキュリティ プロトコルを定義します。既定値は PLAINTEXT です

Returns:

セキュリティ プロトコル。

sslCaLocation

public String sslCaLocation() default ""

ブローカーの証明書を確認するための CA 証明書ファイルへのパス。 librdkafka の ssl.ca.location

Returns:

CA 証明書ファイルへのパス。

sslCertificateLocation

public String sslCertificateLocation() default ""

クライアントの証明書へのパス。 librdkafka 内の ssl.certificate.location

Returns:

SSL 証明書の場所。

sslKeyLocation

public String sslKeyLocation() default ""

認証に使用されるクライアントの秘密キー (PEM) へのパス。 librdkafka の既定の "" ssl.key.location

Returns:

ssl キーの場所。

sslKeyPassword

public String sslKeyPassword() default ""

クライアントの証明書のパスワード。 librdkafka の ssl.key.password

Returns:

ssl キーのパスワード。

topic

public String topic()

トピックを定義します。

Returns:

トピック。

username

public String username() default ""

PLAIN と SASL-SCRAM を使用した SASL ユーザー名-.. メカニズム 既定: ""

Returns:

SASL ユーザー名。

適用対象