1下载和安装Pulsar
1.1下载方式
1)https://archive.apache.org/dist/pulsar/pulsar-2.3.0/apache-pulsar-2.3.0-bin.tar.gz
2)使用wget https://archive.apache.org/dist/pulsar/pulsar-2.3.0/apache-pulsar-2.3.0-bin.tar.gz
需要在群集中的每台计算机上安装Pulsar,包括运行ZooKeeper和BookKeeper的计算机。
3.2解压缩并cd进入生成的目录:
tar xvzf apache-pulsar-2.3.0-bin.tar.gz
cd apache-pulsar-2.3.0
目录包含以下子目录:
|
目录 |
包含 |
|
bin |
Pulsar的命令行工具,如pulsar和pulsar-admin |
|
conf |
Pulsar的配置文件,包括broker配置,ZooKeeper配置等 |
|
data |
ZooKeeper和BookKeeper使用的数据存储目录。 |
|
lib |
Pulsar使用的JAR文件。 |
|
logs |
安装创建的日志。 |
2.2部署ZooKeeper集群
已经有一个现有的zookeeper群集并且使用它。
启动zookeeper集群
/opt/module/zookeeper/bin/zkServer.sh start
2.3初始化群集元数据
初始化群集元数据命令如下:
|
bin/pulsar initialize-cluster-metadata \ –cluster pulsar-cluster-1 \ –zookeeper hadoop101:2181 \ –configuration-store hadoop101:2181 \ –web-service-url http://hadoop101:8080 \ –web-service-url-tls https://hadoop101:8443 \ –broker-service-url pulsar://hadoop101:6650 \ –broker-service-url-tls pulsar+ssl://hadoop101:6651 |
从上面的示例中可以看出,需要指定以下内容: