Installez Apache Kafka sur Ubuntu
Installation d'Apache Kafka
Mettez d'abord à jour le cache du référentiel de package de votre serveur Ubuntu avec la commande suivante:
$ sudo apt-get updat
Le cache du référentiel de packages doit être mis à jour.
Apache Kafka dépend de Java. Vous pouvez installer OpenJDK 8 sur Ubuntu 17.10 du référentiel de packages officiels.
Exécutez la commande suivante pour installer OpenJdk 8 sur Ubuntu 17.dix:
$ sudo apt-get install openjdk-8-jdk
Maintenant appuyez sur «y» puis appuyez pour continuer.
OpenJDK 8 doit être installé.
Vous devez maintenant installer gardien de zoo. Il est disponible dans le référentiel officiel de package d'Ubuntu.
À installer gardien de zoo, Exécutez la commande suivante:
$ sudo apt-get install zookeeperd
Maintenant appuyez sur «y» puis appuyez pour continuer.
gardien de zoo devrait être installé.
Vous pouvez exécuter la commande suivante pour vérifier si gardien de zoo est en cours d'exécution:
$ sudo systemctl status zookeeper
Comme vous pouvez le voir sur la capture d'écran ci-dessous, gardien de zoo est en cours d'exécution.
S'il ne fonctionne pas sur votre machine pour une raison quelconque, vous pouvez commencer gardien de zoo avec la commande suivante:
$ sudo systemctl start zookeeper
Tu devrais ajouter gardien de zoo au démarrage du système. Il démarrera donc automatiquement sur le démarrage.
Exécutez la commande suivante pour ajouter gardien de zoo au démarrage du système:
$ sudo systemctl Activer Zookeeper
gardien de zoo doit être ajouté au démarrage du système comme vous pouvez le voir sur la capture d'écran ci-dessous.
J'ai besoin netstat commande qui est fournie par le outils emballer.
Installer maintenant outils Package avec la commande suivante:
$ sudo apt-get install net-tools
outils Le package doit être installé.
Vous pouvez maintenant exécuter la commande suivante pour vérifier si Zookeeper fonctionne sur le port 2181.
$ sudo netstat -tulpen | grep 2181
Comme vous pouvez le voir, il fonctionne sur le port 2181.
Maintenant, exécutez la commande suivante pour accéder au répertoire ~ / téléchargements / dans le répertoire de votre utilisateur:
$ cd ~ / téléchargements
Maintenant, vous devez télécharger Apache Kafka. Au moment de la rédaction du moment, la dernière version d'Apache Kafka est V1.0.0.
Exécutez la commande suivante pour télécharger Apache Kafka 1.0.0 avec wget:
$ wget http: // www-uu.apache.org / dist / kafka / 1.0.0 / kafka_2.12-1.0.0.tgz
L'archive compressée Apache Kafka doit être téléchargée.
Comme vous pouvez le voir sur la sortie de la commande LS, le nom de fichier d'Apache Kafka Archive est kafka_2.12-1.0.0.tgz
Créez maintenant un répertoire Kafka / dans le /opter Répertoire avec la commande suivante:
$ sudo mkdir / opt / kafka
Un répertoire / opt / kafka devrait être créé. C'est là que je vais extraire les archives.
Extraire maintenant les archives Apache Kafka dans le / opt / kafka Répertoire avec la commande suivante:
$ sudo tar xvzf kafka_2.12-1.0.0.tgz -c / opt / kafka
Les archives doivent être extraites.
Vous pouvez exécuter la commande suivante pour vérifier le nom du répertoire:
$ ls / opt / kafka
Notez que le nom du répertoire.
Ouvert / etc / profil avec la commande suivante:
$ sudo nano / etc / profil
Ajoutez les lignes suivantes à la fin du fichier et enregistrez-la.
Open maintenant le ~ /.bashrc fichier avec la commande suivante:
$ sudo nano ~ /.bashrc
Ajoutez la ligne marquée à la fin du fichier comme enregistrez-le.
Redémarrez maintenant votre ordinateur avec la commande suivante:
$ sudo redémarrer
Une fois votre ordinateur au début, vous pouvez vérifier si les variables d'environnement sont ajoutées comme suit:
$ echo $ kafka_home
$ echo $ chemin
Maintenant pour nous faciliter la vie, faites un lien symbolique de Kafka serveur.propriétés Fichier comme suit:
$ sudo ln -s $ kafka_home / config / serveur.Propriétés / etc / kafka.propriétés
Comme vous pouvez le voir dans la capture d'écran ci-dessous, le lien symbolique est créé.
Vous pouvez maintenant démarrer Apache Kafka Server avec la commande suivante:
$ sudo kafka-server-start.sh / etc / kafka.propriétés
Le serveur Apache Kafka devrait être démarré.
Tester le serveur Apache Kafka
Vous pouvez créer un sujet de test essai Sur le serveur Kafka Apache avec la commande suivante:
$ sudo kafka-topics.sh --create --zookeeper localhost: 2181 - Réplication-facteur 1
--Partitions 1 - Test topic
UN essai Le sujet doit être créé comme indiqué dans la capture d'écran ci-dessous.
Maintenant, exécutez la commande suivante pour utiliser l'API de producteur Kafka pour envoyer un message au essai sujet:
$ sudo kafka-console producteur.SH - Broker-list localhost: 9092 - Test topic
Une fois que vous appuyez sur, vous devriez voir un nouveau panneau Arrow (>) comme indiqué dans la capture d'écran ci-dessous.
Tapez simplement quelque chose et appuyez pour démarrer une nouvelle ligne. J'ai tapé 3 lignes de textes.
Vous pouvez maintenant utiliser l'API Consumer Kafka pour récupérer les messages / lignes de la essai Sujet avec la commande suivante:
$ sudo kafka-consoleur-conscumeuse.sh --zookeeper localhost: 2181 --
Test de sujets - de la bêtises
Vous devriez être en mesure de voir les messages ou les lignes que vous avez écrits en utilisant l'API du producteur comme marqué dans la capture d'écran ci-dessous.
Si vous écrivez un nouveau message en utilisant l'API du producteur, il doit également être affiché instantanément du côté consommateur comme indiqué dans la capture d'écran ci-dessous.
C'est ainsi que vous installez Apache Kafka et vérifiez son travail sur Ubuntu 17.10 Aardvark astucieux. Merci d'avoir lu cet article.