Skip to content
GitLab
Projects Groups Snippets
  • /
  • Help
    • Help
    • Support
    • Community forum
    • Submit feedback
    • Contribute to GitLab
  • Sign in
  • R RIE-2017-ProjetTutore-G1
  • Project information
    • Project information
    • Activity
    • Labels
    • Members
  • Repository
    • Repository
    • Files
    • Commits
    • Branches
    • Tags
    • Contributors
    • Graph
    • Compare
  • Issues 12
    • Issues 12
    • List
    • Boards
    • Service Desk
    • Milestones
  • Merge requests 0
    • Merge requests 0
  • CI/CD
    • CI/CD
    • Pipelines
    • Jobs
    • Schedules
  • Deployments
    • Deployments
    • Environments
    • Releases
  • Packages and registries
    • Packages and registries
    • Container Registry
  • Monitor
    • Monitor
    • Incidents
  • Analytics
    • Analytics
    • Value stream
    • CI/CD
    • Repository
  • Wiki
    • Wiki
  • Snippets
    • Snippets
  • Activity
  • Graph
  • Create a new issue
  • Jobs
  • Commits
  • Issue Boards
Collapse sidebar

Due to inactivity, this project is scheduled to be deleted on 2035-04-24. Why is this scheduled?

  • Lionel Ferrafiat
  • RIE-2017-ProjetTutore-G1
  • Wiki
  • page2 serveur message setup

page2 serveur message setup · Changes

Page history
Mettre à jour page2 serveur message setup authored Sep 28, 2018 by Romain Benit's avatar Romain Benit
Hide whitespace changes
Inline Side-by-side
page2-serveur-message-setup.md
View page @ c296b06c
Page Wiki sur le serveur de message
Installation de Apache KAFKA sur notre serveur virtuel:
**Installation de Apache KAFKA**
Sur notre serveur virtuel nous avons entré les commandes suivantes:
`yum install wget`
......@@ -10,18 +12,19 @@ Installation de Apache KAFKA sur notre serveur virtuel:
`cd kafka_2.10-0.10.2.1/`
Maintenant que nous avons installé le package kafka, qui va gérer la file de messages, nous devons installer un zookeeper. Celui-ci est en charge de réaliser la synchronisation des différents éléments d'un cluster.
Maintenant que nous avons installé le package kafka, qui va gérer la file de messages, nous devons installer un zookeeper.
Zookeeper fonctionne sur la base de JAVA, il faut au préalable vérifier que ce dernier est fonctionnel sur notre serveur:
Celui-ci est en charge de réaliser la synchronisation des différents éléments d'un cluster. Il fonctionne sur la base de JAVA, il faut au préalable vérifier que ce dernier est fonctionnel sur notre serveur:
`yum install java-1.8.0-openjdk-devel`
La version kafka téléchargée auparavant contient les binaires de Apache Zookeeper.
On peut vérifier sa configuration dans le dossier suivant :
La version kafka téléchargée auparavant contient les binaires de Apache Zookeeper, on peut vérifier sa configuration dans le dossier suivant :
`config/zookeeper.properties`
Il ne nous reste plus qu'à le lancer:
**Lancement des services**
Il ne nous reste plus qu'à lancer le service de zookeeper avec la commande suivante :
`./bin/zookeeper-server-start.sh ./config/zookeeper.properties`
......@@ -46,7 +49,9 @@ Trying 127.0.0.1...
Connected to localhost`
==> Nous voilà avec un Zookeeper et un broker Kafka, qui représent un cluster Kafka minimal
==> Nous voilà avec un Zookeeper et un broker Kafka, qui représent un cluster Kafka minimal.
**Création d'un topic "test"**
Dans Kafka, un message est appelé "Record"; les records sont regroupés par "Topic" ou sujet.
On va tout d'abord créé par exemple un topic "test" grâce à un script disponible:
......@@ -63,16 +68,18 @@ Ou même afficher les détails du topic:
`./bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test`
**Echange de messages entre producteurs et consommateurs**
Dans Kafka, les messages sont produits par des producers (ou producteurs) et consommés par des consumers (ou consommateurs). On peut "écrire" et "lire" des records (donc message) de la manière suivante:
Sur le producer:
Sur le producteur :
A savoir => Chaque ligne que l'on écrit après cette commande sera considérée comme un message
`./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test`
`Bonjour comment allez-vous?`
Sur le consumer:
Sur le consommateur :
`./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test`
......
Clone repository
  • Aide pour Soutenance
  • Home
  • page1 serveur web setup
  • page2 1 serveur message php
  • page2 serveur message setup
  • page3 1 blockchain centos
  • page3 blockchain setup
  • page4 serveur vm setup
  • page5 docs techniques divers
  • page6 1 securisation tls ssl
  • page6 2 Securisation En tête Serveur (Server Header)
  • page6 3 securisation Apache2
  • page6 serveur site web
  • page7 utilisation de git
  • page8 realisation des tests