2.7.1

Translate

Managing Clusters

Les clusters Pulsar sont constitués de un ou plusieur brokers Pulsar, un ou plusieur serveurs BookKeeper (alias bookies), et un cluster ZooKeeper qui assure la gestion de la configuration et de la coordination.

Les cluster peuvent être gérés via:

Ressources des clusters

Provisionnement

De nouveaux clusters peuvent être provisionnés en utilisant l'interface d'administration.

Veuillez noter que cette opération nécessite des privilèges superutilisateur.

You can provision a new cluster using the create subcommand. Here's an example:

$ pulsar-admin cluster create cluster-1 \
  --url http://my-cluster.org.com:8080 \
  --broker-url pulsar://my-cluster.org.com:6650
ClusterData clusterData = new ClusterData(
        serviceUrl,
        serviceUrlTls,
        brokerServiceUrl,
        brokerServiceUrlTls
);
admin.clusters().createCluster(clusterName, clusterData);

Initialiser les métadonnées du cluster

Lorsque vous provisionnez un nouveau cluster, vous devez initialiser les métadonnées de ce cluster . Lors de l'initialisation des métadonnées du cluster, vous devez spécifier toutes les données suivantes :

  • Le nom du cluster
  • La chaîne de connexion ZooKeeper locale pour le cluster
  • The configuration store connection string for the entire instance
  • URL du service web pour le cluster
  • URL de service du broker permettant une interaction avec les brokers du cluster

You must initialize cluster metadata before starting up any brokers that will belong to the cluster.

Aucune initialisation des métadonnées du cluster via l'API REST ou l'API d'administration Java

Contrairement à la plupart des autres fonctions d'administration de Pulsar, l'initialisation des métadonnées de cluster ne peut pas être effectuée via l'API REST admin ou le client Java admin, car l'initialisation des métadonnées implique la communication directer avec ZooKeeper. Au lieu de cela, vous pouvez utiliser l'outil pulsar CLI, en particulier la commande initialiser-cluster-metadata.

Voici une commande d'initialisation des métadonnées de cluster par exemple :

bin/pulsar initialize-cluster-metadata \
  --cluster us-west \
  --zookeeper zk1.us-west.example.com:2181 \
  --configuration-store zk1.us-west.example.com:2184 \
  --web-service-url http://pulsar.us-west.example.com:8080/ \
  --web-service-url-tls https://pulsar.us-west.example.com:8443/ \
  --broker-service-url pulsar://pulsar.us-west.example.com:6650/ \
  --broker-service-url-tls pulsar+ssl://pulsar.us-west.example.com:6651/

Vous devrez utiliser les drapeaux --*-tls uniquement si vous utilisez l'authentification TLS dans votre instance.

Get configuration

Vous pouvez récupérer la configuration pour un cluster existant à tout moment.

Use the get subcommand and specify the name of the cluster. Here's an example:

$ pulsar-admin clusters get cluster-1
{
    "serviceUrl": "http://my-cluster.org.com:8080/",
    "serviceUrlTls": null,
    "brokerServiceUrl": "pulsar://my-cluster.org.com:6650/",
    "brokerServiceUrlTls": null
    "peerClusterNames": null
}
admin.clusters().getCluster(clusterName);

Mise à jour

Vous pouvez récupérer la configuration pour un cluster existant à tout moment.

Utilisez la sous-commande update et spécifiez de nouvelles valeurs de configuration en utilisant des drapeaux.

$ pulsar-admin clusters update cluster-1 \
  --url http://my-cluster.org.com:4081 \
  --broker-url pulsar://my-cluster.org.com:3350
ClusterData clusterData = new ClusterData(
        serviceUrl,
        serviceUrlTls,
        brokerServiceUrl,
        brokerServiceUrlTls
);
admin.clusters().updateCluster(clusterName, clusterData);

Delete

Les Clusters peuvent être supprimés d'une instance Pulsar.

Utilisez la sous-commande delete et spécifiez le nom du cluster. Voici un exemple:

$ pulsar-admin clusters delete cluster-1
admin.clusters().deleteCluster(clusterName);

List

Vous pouvez récupérer une liste de tous les clusters dans une instance de Pulsar.

Utilisez la sous-commande liste.

$ pulsar-admin clusters list
cluster-1
cluster-2
admin.clusters().getClusters();

Mettre à jour les données du cluster pair

Les clusters pairs peuvent être configurés pour un cluster donné dans une instance de Pulsar.

Utilisez la sous-commande update-peer-clusters et spécifiez la liste des noms de cluster pairs.

$ pulsar-admin update-peer-clusters cluster-1 --peer-clusters cluster-2
admin.clusters().updatePeerClusterNames(clusterName, peerClusterList);
← OverviewTenants →