Instale Apache Kafka no Ubuntu
Instalando o Apache Kafka
Atualize primeiro o cache do repositório de pacotes do seu servidor Ubuntu com o seguinte comando:
Atualização $ sudo apt-get
O cache do repositório de pacotes deve ser atualizado.
Apache Kafka depende de Java. Você pode instalar o OpenJDK 8 no Ubuntu 17.10 do repositório oficial do pacote.
Execute o seguinte comando para instalar o OpenJDK 8 no Ubuntu 17.10:
$ sudo apt-get install OpenJDK-8-JDK
Agora pressione 'y' e depois pressione para continuar.
OpenJdk 8 deve ser instalado.
Agora você tem que instalar funcionário do zoológico. Está disponível no repositório oficial do pacote do Ubuntu.
Para instalar funcionário do zoológico, Execute o seguinte comando:
$ sudo apt-get install zookeeperd
Agora pressione 'y' e depois pressione para continuar.
funcionário do zoológico deve ser instalado.
Você pode executar o seguinte comando para verificar se funcionário do zoológico está correndo:
$ sudo Systemctl Status Zookeeper
Como você pode ver na captura de tela abaixo, funcionário do zoológico está correndo.
Se não estiver funcionando em sua máquina por algum motivo, você pode começar funcionário do zoológico com o seguinte comando:
$ sudo systemctl start zookeeper
Você deve adicionar funcionário do zoológico para a inicialização do sistema. Portanto, começará automaticamente na inicialização.
Execute o seguinte comando para adicionar funcionário do zoológico para a inicialização do sistema:
$ sudo systemctl Ativar Zookeeper
funcionário do zoológico deve ser adicionado à inicialização do sistema, como você pode ver na captura de tela abaixo.
Eu preciso de netstat comando que é fornecido pelo Toolas de rede pacote.
Agora instale Toolas de rede Pacote com o seguinte comando:
$ sudo apt-get install let tools
Toolas de rede o pacote deve ser instalado.
Agora você pode executar o seguinte comando para verificar se o Zookeeper está sendo executado na porta 2181.
$ sudo netstat -tulpen | Grep 2181
Como você pode ver, está sendo executado na porta 2181.
Agora execute o seguinte comando para navegar para o diretório ~/ downloads/ no diretório inicial de seus usuários:
$ CD ~/Downloads
Agora você tem que baixar Apache Kafka. No momento da redação deste artigo, a versão mais recente do Apache Kafka é v1.0.0.
Execute o seguinte comando para baixar o apache kafka 1.0.0 com wget:
$ wget http: // www-eu.apache.org/dist/kafka/1.0.0/kafka_2.12-1.0.0.TGZ
O arquivo comprimido de Apache Kafka deve ser baixado.
Como você pode ver na saída do comando ls, o nome do arquivo do arquivo Apache Kafka é kafka_2.12-1.0.0.TGZ
Agora crie um diretório Kafka/ no /optar Diretório com o seguinte comando:
$ sudo mkdir /opt /kafka
Um diretório /opt/kafka deve ser criado. É aqui que vou extrair o arquivo.
Agora extraia o arquivo Apache Kafka no /opt/kafka Diretório com o seguinte comando:
$ sudo tar xvzf kafka_2.12-1.0.0.tgz -c /opt /kafka
O arquivo deve ser extraído.
Você pode executar o seguinte comando para verificar o nome do diretório:
$ ls /opt /kafka
Observe que o nome do diretório.
Agora aberto /etc/perfil com o seguinte comando:
$ sudo nano /etc /perfil
Adicione as seguintes linhas ao final do arquivo e salve -o.
Agora abra o ~/.Bashrc Arquivo com o seguinte comando:
$ sudo nano ~//.Bashrc
Adicione a linha marcada ao final do arquivo, pois salve -o.
Agora reinicie seu computador com o seguinte comando:
$ sudo reiniciar
Depois que o computador começar, você pode verificar se as variáveis de ambiente são adicionadas da seguinte forma:
$ echo $ kafka_home
$ ECHO $ PATH
Agora, para facilitar nossa vida, faça um vínculo simbólico de Kafka servidor.propriedades Arquivo o seguinte:
$ sudo ln -s $ kafka_home/config/servidor.propriedades /etc /kafka.propriedades
Como você pode ver na captura de tela abaixo, o link simbólico é criado.
Agora você pode iniciar o Apache Kafka Server com o seguinte comando:
$ sudo kafka-server-start.sh /etc /kafka.propriedades
O servidor Apache Kafka deve ser iniciado.
Testando o servidor Apache Kafka
Você pode criar um tópico de teste teste No servidor Apache Kafka com o seguinte comando:
$ sudo kafka-topics.Sh-Create-Zoookeeper localhost: 2181-Replicação-fator 1
--Partições 1 -Teste -tópico
A teste O tópico deve ser criado como mostrado na captura de tela abaixo.
Agora execute o seguinte comando para usar a API do produtor Kafka para enviar alguma mensagem para o teste tema:
$ sudo kafka-console-produtor.SH-Localhost de Lista de Boscadores: 9092-Testes Tópicos
Depois de pressionar, você deve ver um novo sinal de seta (>), conforme mostrado na captura de tela abaixo.
Basta digitar algo e pressionar para iniciar uma nova linha. Eu digitei em 3 linhas de textos.
Agora você pode usar a API do consumidor Kafka para buscar as mensagens/linhas do teste Tópico com o seguinte comando:
$ sudo kafka-consumer-consumer.sh -zookeeper localhost: 2181 --
Teste de tópicos-de adiamento
Você deve ver as mensagens ou linhas que você escreveu usando a API do produtor, conforme marcado na captura de tela abaixo.
Se você escrever uma nova mensagem usando a API do produtor, ela também deve ser exibida instantaneamente no lado do consumidor, como mostrado na captura de tela abaixo.
É assim que você instala o Apache Kafka e verifica seu trabalho no Ubuntu 17.10 Aardvark artístico. Obrigado por ler este artigo.