Tutorial Apache Kafka - Instalação no Ubuntu Linux [ Passo a Passo ]

Você gostaria de aprender como fazer uma instalação Apache Kafka no Ubuntu Linux? Neste tutorial, vamos mostrar como baixar e instalar o Apache Kafka em um computador rodando o Ubuntu Linux.

• Ubuntu 18.04
• Ubuntu 19.04
• Ubuntu 19.10
• Apache Kafka 2.12-2.3.1
• Versão Openjdk 11.0.4

Lista de hardware:

A seção a seguir apresenta a lista de equipamentos usados para criar este tutorial Apache Kafka.

Cada pedaço de hardware listado acima pode ser encontrado no site da Amazon.

Tutorial relacionado a Apache Kafka:

Nesta página, oferecemos acesso rápido a uma lista de tutoriais relacionados ao Apache Kafka.

Lista de Tutoriais - Apache Kafka

Tutorial Apache Kafka - Instalação no Ubuntu Linux

Instale o pacote Java JDK.

Copy to Clipboard

Use o seguinte comando para encontrar o diretório de instalação Java JDK.

Copy to Clipboard

Esta saída de comando deve mostrar-lhe o diretório de instalação Java.

Copy to Clipboard

Em nosso exemplo, nosso Java JDK está instalado a pasta: /usr/lib/jvm/java-11-openjdk-amd64

Agora, você precisa criar uma variável ambiental chamada JAVA_HOME.

Vamos criar um arquivo para automatizar a configuração de variáveis de ambiente necessárias

Copy to Clipboard

Aqui está o java.sh conteúdo de arquivo.

Copy to Clipboard

Reinicie o computador.

Copy to Clipboard

Use o seguinte comando para verificar se a variável JAVA_HOME foi criada.

Copy to Clipboard

Aqui está a saída de comando:

Copy to Clipboard

Use o seguinte comando para testar a instalação java.

Copy to Clipboard

Aqui está a saída de comando:

Copy to Clipboard

Instale o pacote Zookeeperd.

Copy to Clipboard

Verifique se o serviço Zookeeperd está em execução.

Copy to Clipboard

Aqui está a saída de comando:

Copy to Clipboard

Configure zookeeperd para iniciar automaticamente durante o tempo de inicialização.

Copy to Clipboard

Baixe o pacote Apache Kafka.

Copy to Clipboard

Instale o servidor Apache Kafka.

Copy to Clipboard

Agora, você precisa criar uma variável de ambiente chamada KAFKA_HOME.

Vamos criar um arquivo para automatizar a configuração de variáveis de ambiente necessárias

Copy to Clipboard

Aqui está o conteúdo do arquivo kafka.sh.

Copy to Clipboard

Reinicie o computador.

Copy to Clipboard

Use o seguinte comando para verificar se a variável KAFKA_HOME foi criada.

Copy to Clipboard

Aqui está a saída de comando:

Copy to Clipboard

Crie um link simbólico para facilitar a encontrar o arquivo de configuração Kafka.

Copy to Clipboard

Inicie o serviço Apache Kafka.

Copy to Clipboard

Aqui está uma amostra das informações que devem ser exibidas:

Copy to Clipboard

[2019-10-26 04:29:08,014] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
[2019-10-26 04:29:08,778] INFO Registered signal handlers for TERM, INT, HUP (org.apache.kafka.common.utils.LoggingSignalHandler)
[2019-10-26 04:29:08,782] INFO starting (kafka.server.KafkaServer)
[2019-10-26 04:29:08,786] INFO Connecting to zookeeper on localhost:2181 (kafka.server.KafkaServer)
[2019-10-26 04:29:08,829] INFO [ZooKeeperClient Kafka server] Initializing a new session to localhost:2181. (kafka.zookeeper.ZooKeeperClient)
[2019-10-26 04:29:09,162] INFO Client environment:zookeeper.version=3.4.14-4c25d480e66aadd371de8bd2fd8da255ac140bcf, built on 03/06/2019 16:18 GMT (org.apache.zookeeper.ZooKeeper)
[2019-10-26 04:29:09,162] INFO Client environment:host.name=ubuntu.local (org.apache.zookeeper.ZooKeeper)
[2019-10-26 04:29:09,163] INFO Client environment:java.version=11.0.4 (org.apache.zookeeper.ZooKeeper)
[2019-10-26 04:29:09,163] INFO Client environment:java.vendor=Ubuntu (org.apache.zookeeper.ZooKeeper)
[2019-10-26 04:29:09,164] INFO Client environment:java.home=/usr/lib/jvm/java-11-openjdk-amd64 (org.apache.zookeeper.ZooKeeper)

Parabéns! Você terminou a instalação apache kafka no Ubuntu Linux.

Apache Kafka - Exemplos de Comando

Use o seguinte comando para criar um tópico chamado TopicTest no servidor Apache Kafka.

Copy to Clipboard

Use o seguinte comando para enviar uma mensagem ao Tópico chamado TopicTest usando a API do Produtor Kafka.

Copy to Clipboard

Digite a mensagem desejada.

Mantenha este terminal aberto.

Copy to Clipboard

Em outro terminal Linux, use o seguinte comando para buscar as mensagens do Tópico chamado TopicTest usando a API do Consumidor Kafka.

Copy to Clipboard

Parabéns! Você é capaz de enviar e receber mensagens de um servidor Apache Kafka.