VT2020-Pulsar-Demo - Revision history

Ali.El-Mufti: /* Début de la démonstration */

2020-12-07T01:48:59Z

Début de la démonstration

← Older revision		Revision as of 01:48, 7 December 2020
Line 26:		Line 26:
	Commencons par déployer un premier cluster		Commencons par déployer un premier cluster
	<pre>		<pre>
	./bin/pulsar standalone ~~-a 127.0.0.1 -nss~~		./bin/pulsar standalone
	</pre>		</pre>
	Puis, créons 5 consommateurs par exemple :		Puis, créons 5 consommateurs par exemple :

Ali.El-Mufti: /* Début de la démonstration */

2020-12-07T01:06:52Z

Début de la démonstration

← Older revision		Revision as of 01:06, 7 December 2020
Line 88:		Line 88:
	<pre>		<pre>
	./bin/pulsar-admin topics subscriptions persistent://public/default/topic1		./bin/pulsar-admin topics subscriptions persistent://public/default/topic1
			</pre>

			=== Interface Web ===

			Pour obtenir une interface web de notre cluster in nous suffit d'installer l'image docker suivante :
			<pre>
			sudo docker run -it -p 3000:3000 --network=host bbonnin/pulsar-express
	</pre>		</pre>

Ali.El-Mufti: /* Début de la démonstration */

2020-12-07T00:57:46Z

Début de la démonstration

← Older revision		Revision as of 00:57, 7 December 2020
Line 87:		Line 87:
	Lister les subscriptions d'un topic		Lister les subscriptions d'un topic
	<pre>		<pre>
	./bin/pulsar-admin topics subscriptions persistent://public/default/~~my-first-topic~~		./bin/pulsar-admin topics subscriptions persistent://public/default/topic1
	</pre>		</pre>

Ali.El-Mufti: /* Déburde la démonstration */

2020-12-07T00:57:03Z

Déburde la démonstration

← Older revision		Revision as of 00:57, 7 December 2020
Line 22:		Line 22:
	- licences : Les fichiers de licences		- licences : Les fichiers de licences

	== ~~Déburde~~ la démonstration ==		== Début de la démonstration ==
	Une fois que l'on est dans le répertoire apache-pulsar-2.7.0, nous pouvons commencer a utiliser certaines commandes		Une fois que l'on est dans le répertoire apache-pulsar-2.7.0, nous pouvons commencer a utiliser certaines commandes
	Commencons par déployer un premier cluster		Commencons par déployer un premier cluster
Line 83:		Line 83:
	Pour lister les topics		Pour lister les topics
	<pre>		<pre>
	*./bin/pulsar-admin topics list-partitioned-topics public/default		./bin/pulsar-admin topics list-partitioned-topics public/default
	</pre>		</pre>
	Lister les subscriptions d'un topic		Lister les subscriptions d'un topic

Ali.El-Mufti: /* Déburde la démonstration */

2020-12-07T00:52:37Z

Déburde la démonstration

← Older revision		Revision as of 00:52, 7 December 2020
Line 38:		Line 38:

	Une fois ces commandes éxectuées, on remarque que dans terminal du consumer, on obtient le message suivant :		Une fois ces commandes éxectuées, on remarque que dans terminal du consumer, on obtient le message suivant :
			<pre>
			01:42:37.605 [pulsar-client-io-1-1] INFO com.scurrilous.circe.checksum.Crc32cIntChecksum - SSE4.2 CRC32C provider initialized
			01:42:37.627 [main] INFO org.apache.pulsar.client.impl.PulsarClientImpl - Client closing. URL: pulsar://localhost:6650/
			01:42:37.634 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ProducerImpl - [topic1] [standalone-1-0] Closed Producer
			01:42:37.637 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ClientCnx - [id: 0xda5b2a84, L:/127.0.0.1:40976 ! R:localhost/127.0.0.1:6650] Disconnected
			01:42:37.641 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ClientCnx - [id: 0xea7443c9, L:/127.0.0.1:40978 ! R:localhost/127.0.0.1:6650] Disconnected
			01:42:37.643 [main] INFO org.apache.pulsar.client.cli.PulsarClientTool - 2 messages successfully produced
			</pre>

			Finalement, si l'on réenvoie une nouvelle requete, mais cette fois ci avec 3 messages à la place de 2 comme ceci :
			<pre>
			bin/pulsar-client produce topic1 --messages "Bonjour je m'appelle Ali, J'ai 22 ans, j'aime bien manger"
			</pre>
			Un nouveau message apparaitra dans le consumer, qui s'arretera vu qu'il a été programmé pour recevoir 5 messages :
			<pre>
			----- got message -----
			key:[null], properties:[], content:Bonjour je m'appelle Ali
			----- got message -----
			key:[null], properties:[], content: J'ai 22 ans
			----- got message -----
			key:[null], properties:[], content: j'aime bien manger
			01:43:46.794 [main] INFO org.apache.pulsar.client.impl.PulsarClientImpl - Client closing. URL: pulsar://localhost:6650/
			01:43:46.803 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ConsumerImpl - [topic1] [subscription1] Closed consumer
			01:43:46.806 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ClientCnx - [id: 0x5c800610, L:/127.0.0.1:40970 ! R:localhost/127.0.0.1:6650] Disconnected
			01:43:46.808 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ClientCnx - [id: 0xa1c62468, L:/127.0.0.1:40972 ! R:localhost/127.0.0.1:6650] Disconnected
			01:43:46.811 [main] INFO org.apache.pulsar.client.cli.PulsarClientTool - 5 messages successfully consumed
			</pre>

			Notons cependant que le consumer que nous avons appelé est configuré pour être un consumer exclusif.

			Dans le bin/pulsar-admin, nous avons énormement d'outils afin de pouvoir obtenir des informations, par exemples, nous pouvons obtenir des informations sur les clusters disponibles :
			Pour afficher les clusters disponibles
			<pre>
			./bin/pulsar-admin clusters list
			</pre>
			Pour Obtenir des informations sur un cluster
			<pre>
			./bin/pulsar-admin clusters get standalone
			</pre>
			Pour créer un topic
			<pre>
			./bin/pulsar-admin topics create-partitioned-topic --partitions 3 my-partitioned-topic
			</pre>
			Pour lister les topics
			<pre>
			*./bin/pulsar-admin topics list-partitioned-topics public/default
			</pre>
			Lister les subscriptions d'un topic
			<pre>
			./bin/pulsar-admin topics subscriptions persistent://public/default/my-first-topic
			</pre>

Ali.El-Mufti: /* Déburde la démonstration */

2020-12-07T00:42:55Z

Déburde la démonstration

← Older revision		Revision as of 00:42, 7 December 2020
Line 34:		Line 34:
	Puis ouvrons un nouveau terminal afin de pouvoir créer des producteurs, on peut envoyer plusieurs messages à la fois, comme par exemple ici Bonjour je m'appelle Ali et J'ai 22 ans :		Puis ouvrons un nouveau terminal afin de pouvoir créer des producteurs, on peut envoyer plusieurs messages à la fois, comme par exemple ici Bonjour je m'appelle Ali et J'ai 22 ans :
	<pre>		<pre>
	bin/pulsar-client produce topic1 — messages "Bonjour je m'appelle Ali, J'ai 22 ans"		bin/pulsar-client produce topic1 --messages "Bonjour je m'appelle Ali, J'ai 22 ans"
	</pre>		</pre>

Ali.El-Mufti at 00:39, 7 December 2020

2020-12-07T00:39:25Z

← Older revision		Revision as of 00:39, 7 December 2020
Line 14:		Line 14:
	cd apache-pulsar-2.7.0		cd apache-pulsar-2.7.0
	</pre>		</pre>

	<tab>
			== Contenu du package ==
	babab
			- bin : Les lignes de commandes de Pulsar
	bababab
			- conf : Les fichiers de configuration de Pulsar tel que la configuration du Broker ou la configuration du ZooKeeper
⚫	</~~tab~~>
			- examples : Un fichier JAR contenant les exemples des fonctions de Pulsar
			- lib : Les fichiers JAR utilisés par Pulsar
			- licences : Les fichiers de licences

			== Déburde la démonstration ==
			Une fois que l'on est dans le répertoire apache-pulsar-2.7.0, nous pouvons commencer a utiliser certaines commandes
			Commencons par déployer un premier cluster
			<pre>
			./bin/pulsar standalone -a 127.0.0.1 -nss
		⚫	</pre>
			Puis, créons 5 consommateurs par exemple :
			<pre>
			./bin/pulsar-client consume -s "subscription1" topic1 -n 5
			</pre>
			Puis ouvrons un nouveau terminal afin de pouvoir créer des producteurs, on peut envoyer plusieurs messages à la fois, comme par exemple ici Bonjour je m'appelle Ali et J'ai 22 ans :
			<pre>
			bin/pulsar-client produce topic1 — messages "Bonjour je m'appelle Ali, J'ai 22 ans"
			</pre>

			Une fois ces commandes éxectuées, on remarque que dans terminal du consumer, on obtient le message suivant :

Ali.El-Mufti at 00:22, 7 December 2020

2020-12-07T00:22:40Z

← Older revision		Revision as of 00:22, 7 December 2020
Line 14:		Line 14:
	cd apache-pulsar-2.7.0		cd apache-pulsar-2.7.0
	</pre>		</pre>
			<tab>
			babab
			bababab
			</tab>

Ali.El-Mufti: /* Installation */

2020-12-07T00:18:13Z

Installation

← Older revision		Revision as of 00:18, 7 December 2020
Line 5:		Line 5:
	L'installation se fait très rapidement et n'a aucun prérequis.		L'installation se fait très rapidement et n'a aucun prérequis.
	Il suffit d'executer les commandes suivantes :		Il suffit d'executer les commandes suivantes :


	<pre>		<pre>
	wget https://archive.apache.org/dist/pulsar/pulsar-2.7.0/apache-pulsar-2.7.0-bin.tar.gz		wget https://archive.apache.org/dist/pulsar/pulsar-2.7.0/apache-pulsar-2.7.0-bin.tar.gz

Ali.El-Mufti: /* Installation */

2020-12-07T00:18:02Z

Installation

← Older revision		Revision as of 00:18, 7 December 2020
Line 3:		Line 3:
	Que ce soit les commandes d'installation ou les commandes d'utilisation, Pulsar est très intuitif et très simple à utiliser.		Que ce soit les commandes d'installation ou les commandes d'utilisation, Pulsar est très intuitif et très simple à utiliser.
	== Installation ==		== Installation ==
			L'installation se fait très rapidement et n'a aucun prérequis.
			Il suffit d'executer les commandes suivantes :


	<pre>		<pre>
	wget https://archive.apache.org/dist/pulsar/pulsar-2.7.0/apache-pulsar-2.7.0-bin.tar.gz		wget https://archive.apache.org/dist/pulsar/pulsar-2.7.0/apache-pulsar-2.7.0-bin.tar.gz
			</pre>
			<pre>
			tar xvfz apache-pulsar-2.7.0-bin.tar.gz
			</pre>
			<pre>
			cd apache-pulsar-2.7.0
	</pre>		</pre>