Managing Brokers

Pulsar 的 broker 由两个组件构成：

  1. HTTP服务，暴露出REST 接口管理及topic查询
  2. 调度器，处理所有的Pulsar 消息传输。

Borker 可以通过以下方式管理：

除了在启动时候可配置外，borker还可以被动态配置

有关完整的broker配置参数列表，请参阅配置页。

Broker资源

列出活跃的broker

获取所有正在服务，可用的活跃broker。

pulsar-admin

REST API

JAVA

  1. $ pulsar-admin brokers list use
  1. broker1.use.org.com:8080

GET /admin/v2/brokers/:cluster

  1. admin.brokers().getActiveBrokers(clusterName)

列出给定Broker所拥有的命名空间列表

找到所有给定broker拥有和服务的的命名空间。

pulsar-admin

REST API

JAVA

  1. $ pulsar-admin brokers namespaces use \  --url broker1.use.org.com:8080
  1. {  "my-property/use/my-ns/0x00000000_0xffffffff": {    "broker_assignment": "shared",    "is_controlled": false,    "is_active": true  }}

GET /admin/v2/brokers/:cluster/:broker/ownedNamespaces

  1. admin.brokers().getOwnedNamespaces(cluster,brokerUrl);

动态Broker配置

配置Pulsar broker的一种方式是，在broker启动时给出配置。

But since all broker configuration in Pulsar is stored in ZooKeeper, configuration values can also be dynamically updated while the broker is running. 当动态更新broker的值，ZooKeeper将会把变化通知到broker，broker将会覆盖所有现有的配置值。

  • pulsar-admin工具的brokers命令，有着多种多样的子命令，这使得你可以动态操作broker配置，你可以更新配置值及更多。
  • Pulsar admin REST API中，动态配置通过/admin/v2/brokers/configuration端点管理。

更新动态配置

pulsar-admin

REST API

JAVA

update-dynamic-config子命令用来更新现有配置。 It takes two arguments: the name of the parameter and the new value using the config and value flag respectively. 下面是关于brokerShutdownTimeoutMs参数的例子：

  1. $ pulsar-admin brokers update-dynamic-config --config brokerShutdownTimeoutMs --value 100

POST /admin/v2/brokers/configuration/:configName/:configValue

  1. admin.brokers().updateDynamicConfiguration(configName, configValue);

列出更新的值

Fetch a list of all potentially updatable configuration parameters.

pulsar-admin

REST API

JAVA

  1. $ pulsar-admin brokers list-dynamic-configbrokerShutdownTimeoutMs

GET /admin/v2/brokers/configuration

  1. admin.brokers().getDynamicConfigurationNames();

列出所有

列出所有已经被动态更新的参数列表。

pulsar-admin

REST API

JAVA

  1. $ pulsar-admin brokers get-all-dynamic-configbrokerShutdownTimeoutMs:100

GET /admin/v2/brokers/configuration/values

  1. admin.brokers().getAllDynamicConfigurations();