KafkaOutput Interface

Pacote:

com.microsoft.azure.functions.annotation

public interface KafkaOutput

KafkaOutput(name = "event", topic = "users", brokerList="broker:29092") OutputBinding<String<output, final ExecutionContext context) { context.getLogger().info("Message:" + message); output.setValue(message); return "{ \"id": "" + System.currentTimeMillis() + "", "description": "" + message + "" }"; }

Resumo do método

Modificador e tipo	Método e descrição
BrokerAuthenticationMode	authenticationMode() Mecanismo SASL a ser usado para autenticação. Padrão: PLAIN
int	batchSize() Define o número máximo de mensagens em lote em um MessageSet. padrão: 10000
String	brokerList() Define a BrokerList.
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>"" or string: treat it as a string whose value is serialized from the parameter </p> </li> <li> <p>binary: treat it as a binary data whose value comes from for example OutputBinding&lt;byte[]&lt;</p> </li>
boolean	enableIdempotence() Quando definido como 'true', o produtor garantirá que as mensagens sejam produzidas com êxito exatamente uma vez e na ordem de produção original. padrão: false
int	maxMessageBytes() Define o tamanho máximo da mensagem de transmissão. Padrão: 1 MB
int	maxRetries() Quantas vezes tentar enviar novamente uma mensagem com falha. **Observação:** padrão: 2 A repetição pode causar reordenação, a menos que EnableIdempotence esteja definido como true.
int	messageTimeoutMs() Tempo limite da mensagem local. Esse valor só é imposto localmente e limita o tempo que uma mensagem produzida aguarda a entrega bem-sucedida. Um tempo de 0 é infinito. Esse é o tempo máximo usado para entregar uma mensagem (incluindo novas tentativas). O erro de entrega ocorre quando a contagem de repetições ou o tempo limite da mensagem são excedidos. default: 300000
String	name() O nome da variável usada em function.json.
String	password() Senha SASL com PLAIN e SASL-SCRAM-.. mecanismos O padrão é texto não criptografado security.protocol em librdkafka
BrokerProtocol	protocol() Obtém ou define o protocolo de segurança usado para se comunicar com agentes padrão é PLAINTEXT
int	requestTimeoutMs() O tempo limite da solicitação do produtor em milissegundos. default: 5000
String	sslCaLocation() Caminho para o arquivo de certificado da AC 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 PEM (chave privada) do cliente usada para autenticação. Padrão "" ssl.key.location em librdkafka
String	sslKeyPassword() Senha do certificado do cliente. ssl.key.password em librdkafka
String	topic() Define o Tópico.
String	username() Nome de usuário SASL com PLAIN e SASL-SCRAM-.. mecanismos Padrão: ""

Detalhes do método

authenticationMode

public BrokerAuthenticationMode authenticationMode() default BrokerAuthenticationMode.NOTSET

Mecanismo SASL a ser usado para autenticação. Padrão: PLAIN

Returns:

O mecanismo SASL.

batchSize

public int batchSize() default 10000

Define o número máximo de mensagens em lote em um MessageSet. padrão: 10000

Returns:

O número máximo de mensagens em lote em um MessageSet.

brokerList

public String brokerList()

Define a BrokerList.

Returns:

A cadeia de caracteres de nome brokerList.

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>"" or string: treat it as a string whose value is serialized from the parameter </p>

</li>

<li>

  <p>binary: treat it as a binary data whose value comes from for example OutputBinding&lt;byte[]&lt;</p>

</li>

Returns:

O dataType que será usado pelo runtime do Functions.

enableIdempotence

public boolean enableIdempotence() default false

Quando definido como 'true', o produtor garantirá que as mensagens sejam produzidas com êxito exatamente uma vez e na ordem de produção original. padrão: false

Returns:

se idempotence está habilitado.

maxMessageBytes

public int maxMessageBytes() default 1000012

Define o tamanho máximo da mensagem de transmissão. Padrão: 1 MB

Returns:

O tamanho máximo da mensagem trnasmit.

maxRetries

public int maxRetries() default 2

Quantas vezes tentar enviar novamente uma mensagem com falha. **Observação:** padrão: 2 A repetição pode causar reordenação, a menos que EnableIdempotence esteja definido como true.

Returns:

O número das tentativas máximas.

messageTimeoutMs

public int messageTimeoutMs() default 300000

Tempo limite da mensagem local. Esse valor só é imposto localmente e limita o tempo que uma mensagem produzida aguarda a entrega bem-sucedida. Um tempo de 0 é infinito. Esse é o tempo máximo usado para entregar uma mensagem (incluindo novas tentativas). O erro de entrega ocorre quando a contagem de repetições ou o tempo limite da mensagem são excedidos. default: 300000

Returns:

O tempo limite da mensagem local.

name

public String name()

O nome da variável usada em function.json.

Returns:

O nome da variável usada em function.json.

password

public String password() default ""

Senha SASL com PLAIN e SASL-SCRAM-.. mecanismos O padrão é texto não criptografado

security.protocol em librdkafka

Returns:

A senha SASL.

protocol

public BrokerProtocol protocol() default BrokerProtocol.NOTSET

Obtém ou define o protocolo de segurança usado para se comunicar com agentes padrão é PLAINTEXT

Returns:

O protocolo.

requestTimeoutMs

public int requestTimeoutMs() default 5000

O tempo limite da solicitação do produtor em milissegundos. default: 5000

Returns:

O tempo limite da solicitação do produtor em milissegundos.

sslCaLocation

public String sslCaLocation() default ""

Caminho para o arquivo de certificado da AC para verificar o certificado do agente. ssl.ca.location em librdkafka

Returns:

O local da ac ssl.

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 PEM (chave privada) 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 do certificado do cliente. ssl.key.password em librdkafka

Returns:

A senha da chave SSL.

topic

public String topic()

Define o Tópico.

Returns:

O nome do tópico.

username

public String username() default ""

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

Returns:

O nome de usuário SASL.