Primers passos amb Apache Kafka
Abans d'instal·lar l'Apache Kafka, heu de tenir instal·lat Java i un compte d'usuari amb privilegis sudo. A més, es recomana tenir una memòria RAM de 2 GB o superior per al bon funcionament de Kafka.
Els passos següents us guiaran sobre com instal·lar l'Apache Kafka.
Instal·lació de Java
És necessari Java per instal·lar Kafka. Comproveu si el vostre Ubuntu té Java instal·lat comprovant la versió amb l'ordre següent:
$ java --versió
Si Java no està instal·lat, utilitzeu les ordres següents per instal·lar Java OpenJDK.
$ sudo apt instal·lar default-jdk
Creació d'un compte d'usuari
Amb Java ja instal·lat, creeu un compte d'usuari no root. També hem de donar-li alguns privilegis sudo afegint l'usuari al grup sudo mitjançant l'ordre següent:
$ sudo adduser linuxhint
$ sudo adduser linuxhint sudo
Inicieu sessió al compte d'usuari acabat de crear.
Instal·lació de Kafka
Heu de descarregar l'últim Apache Kafka des de la pàgina oficial de descàrrega. Baixeu els seus fitxers binaris utilitzant el wget comanda tal com es mostra a continuació:
$ wget https: // downloads.apache.org / kafka / 3.2.3 / kafka_2.12-3.2.3.tgz 
Un cop descarregat el fitxer binari, extreu-lo amb el fitxer pren comanda i moveu el directori extret al fitxer /opt/kafka.
A continuació, creeu el scripts systemd per al Cuider del zoològic i la Kafka serveis que ajuden a iniciar i aturar els serveis.
Utilitzeu un editor que trieu per crear els scripts systemd i enganxeu el contingut següent. Comenceu amb el Zookeeper:
$ sudo nano / etc / systemd / sistema / zookeeper.serveiEnganxeu el següent:
[ Unitat ]Descripció =Servidor Apache Zookeeper
Documentació =http: // zookeeper.apache.org
Requereix =network.target remote-fs.target
Després =network.target remote-fs.target
[ Servei ]
Tipus = simple
ExecStart = / optar / kafka / paperera / zookeeper-server-start.sh / optar / kafka / config / zookeeper.properties
ExecStop = / optar / kafka / paperera / zookeeper-server-stop.sh
Reinicia =on-anormal
[ Instal·lar ]
WantedBy =destí.multiusuari
Desa el fitxer. Creeu el fitxer systemd per al Kafka i enganxeu el contingut següent:
Quan enganxeu, assegureu-vos que heu definit el camí correcte per al Java que heu instal·lat al vostre sistema.
[ Unitat ]Descripció = Servidor Apache Kafka
Documentació =http: // kafka.apache.org / documentació.html
Requereix =servei.zookeeper
[ Servei ]
Tipus = simple
Medi ambient = 'JAVA_HOME=/usr/lib/jvm/java-11-openjdk-amd64'
ExecStart = / optar / kafka / paperera / kafka-server-start.sh / optar / kafka / config / server.properties
ExecStop = / optar / kafka / paperera / kafka-server-stop.sh
Reinicia =on-anormal
[ Instal·lar ]
WantedBy =destí.multiusuari
Un cop fet, apliqueu els canvis tornant a carregar el dimoni systemd:
A continuació, activeu el servei Zookeeper i inicieu-lo amb les ordres següents:
$ sudo systemctl iniciar zookeepe < fort > r fort >
També heu de fer el mateix amb el Kafka:
$ sudo systemctl iniciar kafka
Un cop inicieu els serveis, podeu verificar-ne l'estat abans de crear un tema a Kafka.
El millor de Kafka és que hi ha diversos scripts que podeu utilitzar.
Creem un tema nou anomenat linuxhint1 utilitzant el kafka-topics.sh script amb una partició i una rèplica. Utilitzeu l'ordre següent:
$ sudo -en linuxhint / optar / kafka / paperera / kafka-topics.sh --crear --bootstrap-server localhost: 9092 --factor de replicació 1 --particions 1 --tema linuxhint1 
Tingueu en compte que el nostre tema està creat. Podem veure el missatge anterior per comprovar-ho.
Alternativament, podeu llistar els temes disponibles mitjançant el -llista opció a l'ordre següent. Hauria de tornar el tema que hem creat: S
$ sudo -en linuxhint / optar / kafka / paperera / kafka-topics.sh --llista --bootstrap-server localhost: 9092 
Quan s'està creant el tema Kafka, podeu començar a escriure les dades dels fluxos al Kafka-console-producer.sh i comproveu si es reflecteix en el vostre consumer.sh.
Obriu el vostre intèrpret d'ordres i accediu al tema que hem creat mitjançant el producter.sh tal com es mostra a continuació:
$ sudo -en linuxhint / optar / kafka / paperera / kafka-console-producer.sh --llista-corredor localhost: 9092 --tema linuxhint1 
A continuació, obriu un altre shell i accediu al tema de Kafka mitjançant consumer.sh.
Amb les dues shells obertes, podeu enviar missatges a la consola del productor. Tot el que escriviu es reflecteix a la consola del consumidor confirmant que el nostre Apache Kafka està en funcionament.
Conclusió
Amb aquesta guia, ara teniu tots els passos que podeu seguir per instal·lar Apache Kafka al vostre Ubuntu 22.04. Amb sort, heu aconseguit seguir cada pas i instal·lar el vostre Apache Kafka i crear temes per executar una producció senzilla de consumidors i productors. Podeu implementar el mateix en gran producció.