Noțiuni introductive cu Apache Kafka
Înainte de a instala Apache Kafka, trebuie să aveți instalat Java și un cont de utilizator cu privilegii sudo. Mai mult, este recomandat să aveți o memorie RAM de 2 GB și mai mult pentru funcționarea corectă a lui Kafka.
Următorii pași vă vor ghida despre cum să instalați Apache Kafka.
Instalarea Java
Java este necesar pentru a instala Kafka. Verificați dacă Ubuntu are un Java instalat verificând versiunea utilizând următoarea comandă:
$ java --versiune
Dacă Java nu este instalat, utilizați următoarele comenzi pentru a instala Java OpenJDK.
$ sudo apt instalare default-jdk
Crearea unui cont de utilizator
Cu Java deja instalat, creați un cont de utilizator non-root. De asemenea, trebuie să îi acordăm niște privilegii sudo prin adăugarea utilizatorului la grupul sudo folosind următoarea comandă:
$ sudo adduser linuxhint
$ sudo adduser linuxhint sudo
Conectați-vă la contul de utilizator nou creat.
Instalarea Kafka
Trebuie să descărcați cel mai recent Apache Kafka de pe pagina oficială de descărcare. Descărcați fișierele sale binare folosind wget comandă așa cum se arată în următoarele:
$ wget https: // downloads.apache.org / kafka / 3.2.3 / kafka_2.12-3.2.3.tgz 
Odată ce fișierul binar este descărcat, extrageți-l folosind ia comanda și mutați directorul extras în /opt/kafka.
Apoi, creați scripturi systemd pentru Ingrijitor zoo si Kafka servicii care ajută la pornirea și oprirea serviciilor.
Utilizați un editor la alegere pentru a crea scripturile systemd și lipiți următorul conținut. Începeți cu Zookeeperul:
$ sudo nano / etc / systemd / sistem / zookeeper.serviceLipiți următoarele:
[ Unitate ]Descriere =Server Apache Zookeeper
Documentație =http: // zookeeper.apache.org
Necesită =network.target remote-fs.target
După =network.target remote-fs.target
[ Serviciu ]
Tip =simplu
ExecStart = / opta / kafka / cos / zookeeper-server-start.sh / opta / kafka / config / grădina zoologică.proprietăţi
ExecStop = / opta / kafka / cos / zookeeper-server-stop.sh
Repornire =on-anormal
[ Instalare ]
WantedBy =multi-user.target
Salvați fișierul. Creați fișierul systemd pentru Kafka și inserați următorul conținut:
Când lipiți, asigurați-vă că ați setat calea corectă pentru Java pe care l-ați instalat în sistemul dvs.
[ Unitate ]Descriere =Server Apache Kafka
Documentație =http: // kafka.apache.org / documentation.html
Necesită =zookeeper.service
[ Serviciu ]
Tip =simplu
Mediu inconjurator = „JAVA_HOME=/usr/lib/jvm/java-11-openjdk-amd64”
ExecStart = / opta / kafka / cos / kafka-server-start.sh / opta / kafka / config / server.proprietăţi
ExecStop = / opta / kafka / cos / kafka-server-stop.sh
Repornire =on-anormal
[ Instalare ]
WantedBy =multi-user.target
După ce ați terminat, aplicați modificările reîncărcând demonul systemd:
Apoi, activați serviciul Zookeeper și porniți-l folosind următoarele comenzi:
$ sudo systemctl start zookeepe < puternic > r puternic >
De asemenea, trebuie să faceți același lucru pentru Kafka:
$ sudo systemctl start kafka
Odată ce porniți serviciile, puteți verifica starea acestora înainte de a crea un subiect în Kafka.
Lucrul bun cu Kafka este că există mai multe scripturi pe care le puteți folosi.
Să creăm un subiect nou numit linuxhint1 folosind kafka-topics.sh script cu o partiție și o replicare. Utilizați următoarea comandă:
$ sudo -în linuxhint / opta / kafka / cos / kafka-topics.sh --crea --bootstrap-server gazdă locală: 9092 --factor-replicare 1 --partitii 1 --subiect linuxhint1 
Rețineți că subiectul nostru este creat. Putem vedea mesajul anterior pentru a verifica acest lucru.
Alternativ, puteți enumera subiectele disponibile folosind -listă opțiunea din următoarea comandă. Ar trebui să returneze subiectul pe care l-am creat: S
$ sudo -în linuxhint / opta / kafka / cos / kafka-topics.sh --listă --bootstrap-server gazdă locală: 9092 
Odată cu crearea subiectului Kafka, puteți începe să scrieți datele fluxurilor pe Kafka-console-producer.sh și verificați dacă se reflectă în dvs consumator.sh.
Deschideți shell-ul și accesați subiectul pe care l-am creat folosind producer.sh, așa cum se arată în continuare:
$ sudo -în linuxhint / opta / kafka / cos / kafka-console-producer.sh --lista-broker gazdă locală: 9092 --subiect linuxhint1 
Apoi, deschideți un alt shell și accesați subiectul Kafka folosind consumer.sh.
Cu cele două cochilii deschise, puteți trimite mesaje pe consola producătorului. Orice ați tasta se reflectă în consola pentru consumatori, confirmând faptul că Apache Kafka este în funcțiune.
Concluzie
Cu acest ghid, aveți acum toți pașii pe care îi puteți urma pentru a instala Apache Kafka în Ubuntu 22.04. Sper că ați reușit să urmați fiecare pas și să vă instalați Apache Kafka și să creați subiecte pentru a rula o producție simplă pentru consumatori și producători. Puteți implementa același lucru în producția mare.