KafkaTrigger Interface

Pacote:

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

Resumo do método

Modificador e tipo	Método e descrição
BrokerAuthenticationMode	authenticationMode() Mecanismo SASL a ser usado para autenticação. Valores permitidos: Gssapi, Plain, ScramSha256, ScramSha512 Default: PLAIN
String	brokerList() Define a BrokerList.
Cardinality	cardinality() Cardinalidade da entrada do gatilho. Escolha 'One' se a entrada for uma única mensagem ou "Muitos" se a entrada for uma matriz de mensagens. Se você escolher 'Muitos', defina um dataType. Padrão: 'One'
String	consumerGroup() Define o grupo de consumidores.
String	dataType() Define como o tempo de execução do Functions deve tratar o valor do parâmetro. Os valores possíveis são: <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 a cadeia de conexão do EventHub ao usar o recurso de cabeçalho de protocolo KafkaOutput dos EventHubs do Azure.
String	name() O nome da variável usada no código da função para a solicitação ou o corpo da solicitação.
String	password() Senha SASL com o PLAIN e o SASL-SCRAM-.. mecanismos Padrão: "" security.protocol em librdkafka
BrokerProtocol	protocol() Define que o protocolo de segurança usado para se comunicar com os agentes padrão é PLAINTEXT
String	sslCaLocation() Caminho para o arquivo de certificado de autoridade de certificação para verificar o certificado do agente. ssl.ca.location em librdkafka
String	sslCertificateLocation() Caminho para o certificado do cliente. ssl.certificate.location em librdkafka
String	sslKeyLocation() Caminho para a chave privada (PEM) do cliente usada para autenticação. Padrão "" ssl.key.location em librdkafka
String	sslKeyPassword() Senha para o certificado do cliente. ssl.key.password em librdkafka
String	topic() Define o Tópico.
String	username() Nome de usuário SASL com o PLAIN e o SASL-SCRAM-.. mecanismos Padrão: ""

Detalhes do método

authenticationMode

public BrokerAuthenticationMode authenticationMode() default BrokerAuthenticationMode.NOTSET

Mecanismo SASL a ser usado para autenticação. Valores permitidos: Gssapi, Plain, ScramSha256, ScramSha512 Default: PLAIN

Returns:

O modo de autenticação do agente.

brokerList

public String brokerList()

Define a BrokerList.

Returns:

A brokerList.

cardinality

public Cardinality cardinality() default Cardinality.ONE

Cardinalidade da entrada do gatilho. Escolha 'One' se a entrada for uma única mensagem ou "Muitos" se a entrada for uma matriz de mensagens. Se você escolher 'Muitos', defina um dataType. Padrão: 'One'

Returns:

A cardinalidade.

consumerGroup

public String consumerGroup()

Define o grupo de consumidores.

Returns:

O grupo de consumidores.

dataType

public String dataType() default ""

Define como o tempo de execução do Functions deve tratar o valor do parâmetro. Os valores possíveis são:

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

O dataType que será usado pelo runtime do Functions.

eventHubConnectionString

public String eventHubConnectionString() default ""

Define a cadeia de conexão do EventHub ao usar o recurso de cabeçalho de protocolo KafkaOutput dos EventHubs do Azure.

Returns:

A cadeia de conexão do EventHub.

name

public String name()

O nome da variável usada no código da função para a solicitação ou o corpo da solicitação.

Returns:

O nome da variável usada no código da função para a solicitação ou o corpo da solicitação.

password

public String password() default ""

Senha SASL com o PLAIN e o SASL-SCRAM-.. mecanismos Padrão: ""

security.protocol em librdkafka

Returns:

A senha SASL.

protocol

public BrokerProtocol protocol() default BrokerProtocol.NOTSET

Define que o protocolo de segurança usado para se comunicar com os agentes padrão é PLAINTEXT

Returns:

O protocolo de segurança.

sslCaLocation

public String sslCaLocation() default ""

Caminho para o arquivo de certificado de autoridade de certificação para verificar o certificado do agente. ssl.ca.location em librdkafka

Returns:

O caminho para o arquivo de certificado de autoridade de certificação.

sslCertificateLocation

public String sslCertificateLocation() default ""

Caminho para o certificado do cliente. ssl.certificate.location em librdkafka

Returns:

O local do certificado ssl.

sslKeyLocation

public String sslKeyLocation() default ""

Caminho para a chave privada (PEM) do cliente usada para autenticação. Padrão "" ssl.key.location em librdkafka

Returns:

O local da chave SSL.

sslKeyPassword

public String sslKeyPassword() default ""

Senha para o certificado do cliente. ssl.key.password em librdkafka

Returns:

A senha da chave ssl.

topic

public String topic()

Define o Tópico.

Returns:

O tópico.

username

public String username() default ""

Nome de usuário SASL com o PLAIN e o SASL-SCRAM-.. mecanismos Padrão: ""

Returns:

O nome de usuário SASL.