Usando o cliente Kafka Java

A amostra de API Java™ Kafka é um produtor e consumidor de exemplo escrito em Java, que usa diretamente a API Kafka. É possível executar esta amostra localmente ou no IBM Cloud®.

Para obter desempenho ideal com o cliente Java, é recomendado usar a versão 2.6.0ou posterior. Para obter mais informações, consulte restrição conhecida sobre Java Kafka

O código de amostra está no projeto GitHub de fluxos de eventos. Embora os usuários de amostra usem a API do Kafka para enviar e receber mensagens, a amostra usa a API de administração do Event Streams para criar o tópico que ela envia mensagens para e recebe mensagens de.

Para obter mais informações sobre a configuração e execução da amostra, consulte README.md.

Para obter uma apresentação detalhada de como executar a amostra, consulte Introdução ao Event Streams.

Como usar, fazer download e executar a amostra do Liberty for Java

A amostra IBM® Liberty for Java™ for IBM Cloud® implementa um aplicativo simples que é implementado no tempo de execução do Liberty. O aplicativo usa a API do Kafka para o Event Streams produzir e consumir mensagens. O aplicativo também serve um frontend da web que você pode usar para administração.

É possível localizar o código de amostra no projeto event-streams-samples GitHub.

Usando a propriedade sasl.jaas.config

Se você usar um cliente Kafka em 0.10.2.1 ou posterior, será possível usar a propriedade sasl.jaas.config para configuração do cliente em vez de um arquivo JAAS. Para se conectar ao Event Streams, configure sasl.jaas.config como no exemplo a seguir:

    sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \
    username="USERNAME" \
    password="PASSWORD";</code>

USERNAME e PASSWORD são os valores de sua Event Streams Credenciais de Serviço na guia IBM Cloud.

Se você usar o sasl.jaas.config, os clientes que são executados na mesma JVM poderão usar credenciais diferentes Para obter mais informações, consulte Configurando clientes do Kafka

Para um cliente Kafka anterior, deve-se usar um arquivo de configuração do JAAS para especificar as credenciais. Esse mecanismo é menos conveniente, portanto, use a propriedade sasl.jaas.config.

Migrando um cliente Kafka da versão 0.9.X ou 0.10.X para versões mais recentes do cliente

Se você usar os clientes Java, será possível usar os clientes Kafka versão 0.10 ou mais recente disponíveis publicamente

Você é encorajado a mudar da versão 0.9.X para a versão mais recente. É possível fazer download de um cliente Kafka a partir do https://kafka.apache.org/downloads.

Migrando um cliente do Kafka para a versão 0.10.2.X ou versões mais recentes

Na versão 0.10.2, é possível configurar a autenticação SASL diretamente nas propriedades do cliente em vez de usar um arquivo JAAS. Essa simplificação permite executar vários clientes na mesma JVM usando diferentes conjuntos de credenciais, o que não é possível com um arquivo JAAS.

Conclua as etapas a seguir:

  1. Exclua o arquivo JAAS. A propriedade JVM java.security.auth.login.config=<PATH TO JAAS> também não é mais necessária.

  2. Inclua o seguinte nas propriedades do cliente:

    sasl.mechanism=PLAIN
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="USERNAME" password="PASSWORD";

    USERNAME e PASSWORD são os valores de sua Event Streams Credenciais de Serviço na guia IBM Cloud.