系统要求 在部署Pulsar集群之前,您需要满足以下系统要求:
Linux系统(例如CentOS、Ubuntu等)Java 8或更高版本至少2个主机用于搭建Pulsar集群下载和安装Pulsar 在开始部署Pulsar之前,您需要下载Pulsar的二进制文件并解压缩到一个目录中。您可以从Pulsar官方网站下载最新版本的二进制文件。
假设您已经将Pulsar的二进制文件解压缩到了/opt/pulsar
目录中。在每个Pulsar节点上,您需要设置PULSAR_HOME
环境变量:
【资料图】
export PULSAR_HOME=/opt/pulsar
您还需要将$PULSAR_HOME/bin
添加到$PATH
环境变量中,以便您可以方便地使用Pulsar的命令行工具:
export PATH=$PATH:$PULSAR_HOME/bin
配置ZooKeeper Pulsar需要使用ZooKeeper作为其元数据存储和协调服务。您需要在每个Pulsar节点上安装和配置ZooKeeper。
首先,您需要从ZooKeeper官方网站下载最新版本的二进制文件。然后,将ZooKeeper的二进制文件解压缩到一个目录中(例如/opt/zookeeper
),并在每个Pulsar节点上设置ZOOKEEPER_HOME
环境变量:
export ZOOKEEPER_HOME=/opt/zookeeper
您还需要将$ZOOKEEPER_HOME/bin
添加到$PATH
环境变量中:
export PATH=$PATH:$ZOOKEEPER_HOME/bin
接下来,您需要在每个Pulsar节点上创建一个ZooKeeper配置文件(例如/opt/zookeeper/conf/zoo.cfg
),并在其中添加以下配置:
tickTime=2000initLimit=10syncLimit=5dataDir=/var/lib/zookeeperclientPort=2181
在上面的配置中,tickTime
表示ZooKeeper使用的基本时间单位(以毫秒为单位),initLimit
表示ZooKeeper在启动过程中等待Follower节点同步的最大时间(以tick为单位),syncLimit
表示Leader节点与Follower节点之间的最大时间差(以tick为单位),dataDir
表示ZooKeeper保存其快照和日志的目录,clientPort
表示ZooKeeper客户端连接的端口。
您还需要在每个Pulsar节点上创建一个myid
文件,以指定该节点在ZooKeeper集群中的唯一标识。您可以将任意数字作为myid
文件的内容,例如在节点1上创建一个名为myid
的文件,并将内容设置为1:
echo "1" > /var/lib/zookeeper/myid
对于节点2和节点3,您需要创建相应的myid
文件,并将内容分别设置为2和3。
最后,您需要启动ZooKeeper服务。在节点1上,可以使用以下命令启动ZooKeeper服务:
zkServer.sh start
在节点2和节点3上,也需要启动ZooKeeper服务。
部署Pulsar集群 在完成ZooKeeper的配置之后,您可以开始部署Pulsar集群了。在每个Pulsar节点上,您需要创建一个broker.conf
文件,以指定Pulsar Broker的配置。以下是一个示例broker.conf
文件:
zookeeperServers=zk1:2181,zk2:2181,zk3:2181configurationStoreServers=zk1:2181,zk2:2181,zk3:2181brokerServicePort=6650webServicePort=8080
在上面的配置中,zookeeperServers
和configurationStoreServers
表示Pulsar Broker应该连接的ZooKeeper服务器的列表。brokerServicePort
表示Pulsar Broker应该使用的端口,webServicePort
表示Pulsar Web服务应该使用的端口。
在每个Pulsar节点上,您可以使用以下命令启动Pulsar Broker:
bin/pulsar broker
此命令将启动Pulsar Broker,并将其连接到ZooKeeper集群。
验证Pulsar集群 在完成Pulsar集群的部署之后,您可以使用以下命令验证Pulsar集群是否正常工作:
bin/pulsar-admin brokers list
此命令将列出Pulsar集群中所有可用的Broker节点。
您还可以使用以下命令创建一个主题并发布一些消息:
bin/pulsar-admin topics create my-topicbin/pulsar-client produce my-topic --messages "Hello, World!"
在这些命令中,pulsar-admin
和pulsar-client
是Pulsar命令行工具。topics create
命令用于创建一个新的主题,pulsar-client produce
命令用于发布消息到指定的主题。
您可以使用以下命令消费发布的消息:
bin/pulsar-client consume my-topic
此命令将从my-topic
主题消费已发布的消息。