Comment installer Apache Kafka dans Ubuntu Top 10.Top 10

Apache Kafka est une plate-forme de streaming développée par l'Apache Software Foundation. La plate-forme est ouverte et distribuée, et peut être installée sur n'importe quelle plate-forme à condition qu'il prenne en charge Java. D'ailleurs, Apache Kafka est écrite en Java et Scala. Ce guide donne un tutoriel pratique sur la façon d'installer Apache Kafka dans Ubuntu 22.04.

Début avec Apache Kafka

Avant d'installer l'Apache Kafka, vous devez installer le Java et un compte utilisateur avec les privilèges sudo. De plus, il est recommandé d'avoir un RAM de 2 Go et plus pour le bon fonctionnement de Kafka.

Les étapes suivantes vous guideront sur la façon d'installer l'Apache Kafka.

Installation de Java

Java est nécessaire pour installer Kafka. Vérifiez si votre Ubuntu a un Java installé en vérifiant la version à l'aide de la commande suivante:

$ Java - Version

Si Java n'est pas installé, utilisez les commandes suivantes pour installer le Java OpenJDK.

$ sudo apt mise à jour
$ sudo apt installer par défaut-jdk

Création d'un compte utilisateur

Avec Java déjà installé, créez un compte utilisateur non racinaire. Nous devons également lui donner des privilèges sudo en ajoutant l'utilisateur au groupe sudo en utilisant la commande suivante:

$ sudo addUser Linuxhint
$ sudo addUser Linuxhint sudo

Connectez-vous au compte utilisateur nouvellement créé.

$ su -l Linuxhint

Installation de Kafka

Vous devez télécharger le dernier Apache Kafka à partir de la page de téléchargement officielle. Téléchargez ses fichiers binaires en utilisant le wget Commande comme indiqué dans ce qui suit:

$ wget https: // téléchargements.apache.org / kafka / 3.2.3 / kafka_2.12-3.2.3.tgz

Une fois le fichier binaire téléchargé, extraire en utilisant le le goudron commande et déplacer le répertoire extrait vers le / opt / kafka.

Ensuite, créez le scripts systemd pour le Gardien de zoo et le Kafka services qui aident à démarrer et à arrêter les services.

Utilisez un éditeur de choix pour créer les scripts systemd et coller le contenu suivant. Commencez par le gardien de zoo:

$ sudo nano / etc / systemd / système / zookeeper.service

Collez ce qui suit:

[Unité]
Description = Server Apache ZooKeeper
Documentation = http: // zookeeper.apache.org
Requiert = réseau.Target Remote-FS.cible
After = réseau.Target Remote-FS.cible
[Service]
Type = simple
Execstart = / opt / kafka / bin / zookeeper-server-start.sh / opt / kafka / config / zookeeper.propriétés
Execstop = / opt / kafka / bin / zookeeper-server-stop.shot
Redémarrer = en tant que
[Installer]
Recherché = multi-utilisateurs.cible

Enregistrer le fichier. Créez le fichier systemd pour le kafka et collez le contenu suivant:

$ sudo nano / etc / systemd / système / kafka.service

Lorsque vous collectez, assurez-vous de définir le bon chemin pour le java que vous avez installé dans votre système.

[Unité]
Description = serveur Apache Kafka
Documentation = http: // kafka.apache.org / documentation.html
Requiert = zookeeper.service
[Service]
Type = simple
Environnement = "java_home = / usr / lib / jvm / java-11-openjdk-amd64"
Execstart = / opt / kafka / bin / kafka-server-start.sh / opt / kafka / config / serveur.propriétés
Execstop = / opt / kafka / bin / kafka-server-stop.shot
Redémarrer = en tant que
[Installer]
Recherché = multi-utilisateurs.cible

Une fois terminé, appliquez les modifications en rechargeant le démon systemd:

$ sudo Systemctl Daemon-Reload

Ensuite, activez le service ZooKeeper et démarrez-le en utilisant les commandes suivantes:

$ sudo systemctl Activer Zookeeper
$ sudo systemctl start zookeeper

Vous devez également faire de même pour le kafka:

$ sudo systemctl activer kafka
$ sudo systemctl start kafka

Une fois que vous avez commencé les services, vous pouvez vérifier leur statut avant de créer un sujet à Kafka.

La bonne chose avec Kafka est qu'il y a plusieurs scripts que vous pouvez utiliser.

Créons un nouveau sujet nommé linuxhint1 en utilisant le kafka-topics.shot script avec une partition et une réplication. Utilisez la commande suivante:

$ sudo -u linuxhint / opt / kafka / bin / kafka-topics.sh --create --bootstrap-server localhost: 9092 - Réplication-Factor 1 - Partitions 1 - Topic Linuxhint1

Notez que notre sujet est créé. Nous pouvons voir le message précédent pour le vérifier.

Alternativement, vous pouvez répertorier les sujets disponibles en utilisant le -liste Option dans la commande suivante. Il devrait retourner le sujet que nous avons créé: S

$ sudo -u linuxhint / opt / kafka / bin / kafka-topics.sh - list --bootstrap-server localhost: 9092

Avec le sujet Kafka en cours de création, vous pouvez commencer à écrire les données des flux sur le Kafka-console producteur.shot Et vérifiez si cela se reflète dans votre consommateur.shot.

Ouvrez votre shell et accédez au sujet que nous avons créé à l'aide du producteur.sh comme indiqué dans ce qui suit:

$ sudo -u linuxhint / opt / kafka / bin / kafka-console producteur.SH - Broker-list localhost: 9092 - Topic Linuxhint1

Ensuite, ouvrez un autre shell et accédez au sujet Kafka en utilisant le consommateur.shot.

$ sudo -u linuxhint / opt / kafka / bin / kafka-consoleur-conscumer.sh --bootstrap-server localhost: 9092 - topic Linuxhint1 --from-beginning

Avec les deux coquilles ouvertes, vous pouvez envoyer un message sur la console du producteur. Tout ce que vous tapez se reflète dans la console de consommation confirmant que notre Apache Kafka est opérationnel.

Conclusion

Avec ce guide, vous avez maintenant toutes les étapes que vous pouvez suivre pour installer Apache Kafka dans votre Ubuntu 22.04. J'espère que vous avez réussi à suivre chaque étape et à installer votre Apache Kafka et à créer des sujets pour exécuter une simple production de consommateurs et de producteurs. Vous pouvez implémenter la même production.