通过

你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站，请访问 https://docs.azure.cn。

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

触发器输入的基数。 如果输入是单个消息，请选择“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

触发器输入的基数。 如果输入是单个消息，请选择“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 用户名。

适用于