Comment installer Apache Kafka | Kafdrop sur WindowsPour et intégrer avec Drupal

Apache Kafka est une plate-forme open source de diffusion d’événements distribués. Cela utilise le mécanisme de publication et d’abonnement pour diffuser les enregistrements.​

Téléchargez et installez Apache Kafka :

​Prérequis: Java (JDK) doit être installé sur votre machine Windows.

Étape 1: Téléchargez la version binaire depuis la page de téléchargement officielle de kafka ( https://kafka.apache.org/downloads )

Étape 2: Décompressez-le et renommez le dossier comme kafka_binary et collez le dossier dans le lecteur c comme C:\dev\kafka_binary

Étape 3: Modifiez le paramètre de chemin d’accès au journal dans les fichiers ci-dessous

filename : C:\dev\kafka_binary\config\server.properties​

Change :  log.dirs=/tmp/kafka-logs  =>  log.dirs=C:/dev/kafka_binary/kafka-logs

​               filename : C:\dev\kafka_binary\config\zookeeper.properties

Change : dataDir=C:/tmp/zookeeper  => dataDir=C:/dev/kafka_binary/zookeeper

Kafka est maintenant installé sur votre machine Windows et nous pouvons démarrer le serveur Kafka.

Kafka dépend du service de gardien de zoo, et ce gardien de zoo est déjà intégré à notre serveur ; nous devons donc d’abord démarrer le gardien du zoo, puis nous pouvons démarrer le serveur Kafka.

La commande Kafka utilise 2 fichiers comme paire clé-valeur pour exécuter la commande, cela signifie que pour chaque tâche, il y a 1 fichier dans le dossier .bin\windows, qui fonctionnera avec la combinaison du dossier .\config sur la barre de droite.

comme

 
C:\dev\kafka_binary.\bin\windows\  => .\config\

Kafka utilise avec l’aide de CLI :

Ouvrez l’invite de commande CMD et exécutez les commandes ci-dessous,

Étape 1: Commencer le ZooKeeper service par la commande ci-dessous, il démarrera donc le serveur Zookeeper et le maintiendra en cours d’exécution dans ce terminal ; pour exécuter toute autre commande cmd, utilisez une autre invite de commande.​

C:\dev\kafka_binary.\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties

Démarrer le serveur zookeeper

Étape 2 : Démarrer le courtier Kafka service par la commande ci-dessous. Ainsi, il démarrera le serveur Kafka et le maintiendra en cours d’exécution dans ce terminal ; pour exécuter toute autre commande cmd, utilisez l’autre invite de commande.

C:\dev\kafka_binary\.\bin\windows\kafka-server-start.bat .\config\server.properties​

Démarrer le serveur Kafka

​Étape 3 : Maintenant, nous pouvons créer un sujet pour mémoriser votre événement,

​C:\dev\kafka_binary\.\bin\windows\kafka-topics.bat --create --topic topic_part2 --bootstrap-server localhost:9092

​

Étape 4 : Écrivez quelques événements dans les sujets

C:\dev\kafka_binary\.\bin\windows\kafka-console-producer.bat --topic topic_part2 --bootstrap-server localhost:9092

​Étape -5 : Lisez les messages du sujet que nous avons enregistrés à l’étape -4,

C:\dev\kafka_binary\.\bin\windows\kafka-console-consumer.bat --topic topic_part1 --from-beginning --bootstrap-server localhost:9092

C’est tout le processus pour créer un message dans le sujet et lire le message du sujet.

Téléchargez et installez l’extension PHP rd-Kafka sur Wamp :

J’utilise la version 8.0.26 de Wamp & PHP, si vous avez une autre version de PHP, mettez à jour la commande en conséquence.

Pour activer l’extension rd-kafka sur wamp, nous devons télécharger les fichiers DLL à partir de l’URL ci-dessous,

Référence : https://arnaud.le-blanc.net/php-rdkafka-doc/phpdoc/rdkafka.installation.windows.html

Lien de téléchargement : http://pecl.php.net/package/rdkafka

Avant de télécharger la version correcte, veuillez vérifier les informations de votre système comme ci-dessous

J’utilise la version 5.0.2,

http://pecl.php.net/package/rdkafka/5.0.2/windows

J’ai la configuration ci-dessous sur mon système, veuillez vérifier toutes ces configurations sur votre système si elles diffèrent, puis téléchargez la DLL en fonction de cela, sinon cela ne fonctionnera pas correctement.

php-v = 8.0.26
version rdkafka = 5.0.2
Type de système d’exploitation = 64 bits
Thread sefe = Activé

Étapes pour configurer le rd-kafah extension sur Wamp​ Serveur

Étape 1 : Collez les fichiers DLL que nous téléchargeons ci-dessous Chemins

C:\wamp64\bin\php\php8.0.26\   Paste the librdkafka.dll​

C:\wamp64\bin\php\php8.0.26\ext\ Paste the php_rdkafka.dll​

Étape 2 : Activez l’extension rd-kafka dans les fichiers ci-dessous

C:\wamp64\bin\php\php8.0.26\php.ini  => Add  extension=php_rdkafka.dll​

C:\wamp64\bin\apache\apache2.4.54.2\bin\php.ini   => Add  extension=php_rdkafka.dll​

Redémarrez le serveur et vérifiez avec php –m Il devrait afficher l’extension rdkafka dans la liste

Installer et configurer l’interface utilisateur Web de Kafka – Kafdrop​

Exigence: ​

Java 11 ou plus récent​

Kafka (version 0.11.0 ou plus récente)

Référence pour télécharger le kafdrop : https://github.com/obsidiandynamics/kafdrop/releases​

Étape 1: Téléchargez les fichiers jar à partir de l’URL ci-dessous

curl -LO https://github.com/obsidiandynamics/kafdrop/releases/download/3.30.0/kafdrop-3.30.0.jar​

Étape 2: Renommer le fichier jar

mv kafdrop-3.30.0.jar kafdrop.jar​

Étape 3: Lancer/Exécuter le fichier jar

java –add-opens=java.base/sun.nio.ch=TOUS-SANS NOM \​

-pot /c/kafdrop/kafdrop.jar\​

—kafka.brokerSe connecter=hôtelocal:9092​

Étape 4: visitez http://localhost:9000/​

Il devrait afficher l’interface utilisateur comme ci-dessous. Assurez-vous que le serveur Zookeeper & Kafka est en cours d’exécution.

Installer et configurer le module Drupal :

Nous pouvons télécharger le module kafka drupal depuis le https://www.drupal.org/project/kafka

Utilisez composer pour télécharger le module

compositeur exige ‘drupe/kafka:^1.0@beta’​

Après le téléchargement, activez le module et la mise à jour ci-dessous dans le fichier settings.php pour vous connecter au serveur kafka

$settings['kafka'] = [​
'topic' => 'kafka-demo',​
'consumer' => [​
'brokers' => ['127.0.0.1:9092'],​
],​
'producer' => [​
'brokers' => ['127.0.0.1:9092'],​
],​
];

Maintenant, à partir du menu Drupal, vous pouvez afficher les rapports d’état de Kafka => rapport d’état => Kafka

Cela devrait être quelque chose comme ci-dessous,

C’est ça, félicitations !!