Managing Brokers
Les brokers Pulsar sont constitués de deux composants:
- Un serveur HTTP exposant une REST interface d'administration et une vue du topic .
- Un dispatcher qui gère tous les messages transférés par Pulsar.
Les Brokers peuvent être gérés par:
- La commande
brokersdepulsar-admin - Le point de terminaison
/admin/v2/brokersde l'interface d'administration REST API - La méthode
brokersde l'objet PulsarAdmin dans l'API Java
En plus d'être configurables au démarrage, les broker peuvent également être configurés dynamiquement.
Reportez-vous à la page Configuration pour obtenir la liste complète des paramètres de configuration spécifiques au broker.
Ressources des brokers
Liste des brokers actifs
Récupérer tous les brokers actifs disponibles qui servent le trafic.
$ pulsar-admin brokers list use
broker1.use.org.com:8080
admin.brokers().getActiveBrokers(clusterName)
lister les espaces de noms appartenant à un broker donné
Ceci trouve tous les espaces de noms qui appartiennent et sont servis par un broker donné.
$ pulsar-admin brokers namespaces use \
--url broker1.use.org.com:8080
{
"my-property/use/my-ns/0x00000000_0xffffffff": {
"broker_assignment": "shared",
"is_controlled": false,
"is_active": true
}
}
admin.brokers().getOwnedNamespaces(cluster,brokerUrl);
Configuration dynamique du broker
Un manière de configurer un broker Pulsar est de fournir une configuration quand le broker is démarré.
But since all broker configuration in Pulsar is stored in ZooKeeper, configuration values can also be dynamically updated while the broker is running. Lorsque vous mettez à jour la configuration du courtier de manière dynamique, ZooKeeper informera le broker de la modification et le broker remplacera ensuite les valeurs de configuration existantes.
- La commande
brokerspourpulsar L'outil -admincontient diverses sous-commandes qui vous permettent de manipuler de manière dynamique la configuration d'un broker, ce qui vous permet de mettre à jour les valeurs de configuration et plus. - Dans l'API d'aministration Pulsar REST
, la configuration dynamique est gérée via le point de terminaison
/admin/v2/brokers/configuration.
Modification dynamique de la configuration
La sous-commande update-dynamic-config mettra à jour la configuration existante. It takes two arguments: the name of the parameter and the new value using the config and value flag respectively. Voici l'exemple du paramètre brokerShutdownTimeoutMs:
$ pulsar-admin brokers update-dynamic-config --config brokerShutdownTimeoutMs --value 100
admin.brokers().updateDynamicConfiguration(configName, configValue);
Lister les valeurs modifiées
Fetch a list of all potentially updatable configuration parameters.
$ pulsar-admin brokers list-dynamic-config
brokerShutdownTimeoutMs
admin.brokers().getDynamicConfigurationNames();
Tout lister
Récupérez une liste de tous les paramètres qui ont été modifiés.
$ pulsar-admin brokers get-all-dynamic-config
brokerShutdownTimeoutMs:100
admin.brokers().getAllDynamicConfigurations();