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

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

  • 工具的brokers命令
  • Admin API中的/admin/v2/brokers

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

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

pulsar-admin

  1. broker1.use.org.com:8080
REST
Java
  1. admin.brokers().getActiveBrokers(clusterName)

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

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

CLI
  1. $ pulsar-admin brokers namespaces use \
REST

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

配置Pulsar 的一种方式是，在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工具的命令，有着多种多样的子命令，这使得你可以动态操作broker配置，你可以更新配置值及更多。
  • Pulsar admin API中，动态配置通过/admin/v2/brokers/configuration端点管理。

pulsar-admin

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

REST API

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

Java

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

获取所有可能可更新的配置参数列表。

pulsar-admin

REST API

GET /admin/v2/brokers/configuration

Java

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

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

pulsar-admin

  1. $ pulsar-admin brokers get-all-dynamic-config
  2. brokerShutdownTimeoutMs:100

REST API

Java