Como instalar o Apache Kafka no Ubuntu Top 10.Top 10
Introdução com Apache Kafka
Antes de instalar o apache kafka, você deve instalar o Java e uma conta de usuário com privilégios sudo. Além disso, é recomendável ter uma RAM de 2 GB e acima para a corrida adequada de Kafka.
As etapas a seguir o guiarão sobre como instalar o apache kafka.
Instalando Java
Java é obrigado a instalar Kafka. Verifique se o seu Ubuntu tem um Java instalado verificando a versão usando o seguinte comando:
$ java --version
Se Java não estiver instalado, use os seguintes comandos para instalar o Java OpenJDK.
$ sudo apt update
$ sudo apt install default-jdk
Criando uma conta de usuário
Com o Java já instalado, crie uma conta de usuário sem raios. Também precisamos fornecer alguns privilégios de sudo adicionando o usuário ao grupo sudo usando o seguinte comando:
$ sudo adduser linuxhint
$ sudo adduser linuxhint sudo
Faça login na conta de usuário recém -criada.
$ su -l linuxhint
Instalando Kafka
Você precisa baixar a mais recente Apache Kafka na página de download oficial. Baixar seus arquivos binários usando o wget comando como mostrado no seguinte:
$ wget https: // downloads.apache.org/kafka/3.2.3/kafka_2.12-3.2.3.TGZ
Depois que o arquivo binário for baixado, extraia -o usando o alcatrão comando e mova o diretório extraído para o /opt/kafka.
Em seguida, crie o scripts systemd para o Funcionário do zoológico e a Kafka serviços que ajudam a iniciar e interromper os serviços.
Use um editor de escolha para criar os scripts Systemd e colar o seguinte conteúdo. Comece com o Zookeeper:
$ sudo nano/etc/systemd/system/zookeeper.serviço
Cole a seguinte:
[Unidade]
Descrição = servidor Apache Zookeeper
Documentação = http: // Zookeeper.apache.org
Requer = rede.alvo remoto-fs.alvo
Depois = rede.alvo remoto-fs.alvo
[Serviço]
Tipo = simples
Execstart =/opt/kafka/bin/zookeeper-server-start.sh/opt/kafka/config/zookeeper.propriedades
Execstop =/opt/kafka/bin/zookeeper-server-stop.sh
Reinicie = on-abnormal
[Instalar]
WantedBy = MultiUser.alvo
Salve o arquivo. Crie o arquivo Systemd para o Kafka e cole o seguinte conteúdo:
$ sudo nano/etc/systemd/system/kafka.serviço
Ao colar, certifique -se de definir o caminho certo para o Java que você instalou em seu sistema.
[Unidade]
Descrição = servidor Apache Kafka
Documentação = http: // kafka.apache.org/documentação.html
Requer = zookeeper.serviço
[Serviço]
Tipo = simples
Environment = "Java_home =/usr/lib/jvm/java-11-openjdk-amd64"
Execstart =/opt/kafka/bin/kafka-server-start.sh/opt/kafka/config/servidor.propriedades
Execstop =/opt/kafka/bin/kafka-server-stop.sh
Reinicie = on-abnormal
[Instalar]
WantedBy = MultiUser.alvo
Uma vez feito, aplique as alterações recarregando o daemon Systemd:
$ sudo systemctl daemon -load
Em seguida, ative o serviço Zookeeper e inicie -o usando os seguintes comandos:
$ sudo systemctl Ativar Zookeeper
$ sudo systemctl iniciar o zookeeper
Você também precisa fazer o mesmo para o Kafka:
$ sudo systemctl Ativar kafka
$ sudo systemctl start kafka
Depois de iniciar os serviços, você pode verificar o status deles antes de criar um tópico em Kafka.
A coisa boa com Kafka é que existem vários scripts que você pode usar.
Vamos criar um novo tópico chamado Linuxhint1 usando o Kafka-Topics.sh script com uma partição e uma replicação. Use o seguinte comando:
$ sudo -u linuxhint/opt/kafka/bin/kafka -topics.sh --create --Bootstrap-Server localhost: 9092-Replicação-fator 1-Partições 1-Linuxhint1
Observe que nosso tópico é criado. Podemos ver a mensagem anterior para verificar então.
Como alternativa, você pode listar os tópicos disponíveis usando o -lista opção no seguinte comando. Deve retornar o tópico que criamos: S
$ sudo -u linuxhint/opt/kafka/bin/kafka -topics.SH-LIST-LocalHost de servidor-servidor: 9092
Com o tópico Kafka sendo criado, você pode começar a escrever os dados dos fluxos no Kafka-console-produtor.sh e verifique se reflete em seu consumidor.sh.
Abra sua concha e acesse o tópico que criamos usando o produtor.SH Como mostrado no seguinte:
$ sudo -u linuxhint/opt/kafka/bin/kafka-console-produtor.SH-LocalHost da lista de abordagens: 9092-Linuxhint1
Em seguida, abra outro shell e acesse o tópico Kafka usando o consumidor.sh.
$ sudo -u linuxhint/opt/kafka/bin/kafka-consumidor-consumidor.sh-bootstrap-server localhost: 9092-linuxhint1-de admissão
Com as duas conchas abertas, você pode enviar uma mensagem no console do produtor. Tudo o que você digita é refletido no console do consumidor, confirmando que nosso Apache Kafka está em funcionamento e em funcionamento.
Conclusão
Com este guia, agora você tem todas as etapas que você pode seguir para instalar o Apache Kafka no seu Ubuntu 22.04. Felizmente, você conseguiu seguir cada etapa e instalar seu Apache Kafka e criar tópicos para executar uma produção simples de consumidores e produtores. Você pode implementar o mesmo em grande produção.