乐趣区

关于pulsar:聊聊-Pulsar-在-Linux-环境上搭建-Pulsar

一、环境筹备

jdk 下载地址链接:jdk 1.8,提取码: dv5h
pulsar 下载地址链接:pulsar2.9.1,提取码: 8489

1.1 Java 环境为前提

1.1.1 上传 jdk-8u261-linux-x64.rpm 到服务器并装置

# 装置命令
rpm -ivh jdk-8u261-linux-x64.rpm 

1.1.2 配置环境变量

# 编辑配置文件,jdk 的 bin 目录到 /etc/profile 文件,对所有用户的 shell 无效
vim /etc/profile
# 失效
source /etc/profile

export JAVA_HOME=/usr/java/jdk1.8.0_261-amd64
export PATH=$PATH:$JAVA_HOME/bin

# 验证
java -version


至此,jdk 装置胜利。

1.2 Pulsar 的装置与配置

1.2.1 上传 apache-pulsar-2.9.1-bin.tar.gz 到服务器并解压

tar -zxf apache-pulsar-2.9.1-bin.tar.gz -C /opt 

1.2.2 启动单机模式 Pulsar

./pulsar standalone


间接回车走起,而后呈现以下报错:

很显著,没有足够的内存。

free -m 命令查了下,可用内存还有 957 M,怎么就说内存不够了呢?

查了下文档,原来默认须要 2G 的 JVM 内存。

那我就调整下 pulsar 的默认配置,把默认的 2g 调整成 512m。

vim conf/pulsar_env.sh

PULSAR_MEM=${PULSAR_MEM:-"-Xms512m -Xmx512m -XX:MaxDirectMemorySize=512m"}

source conf/pulsar_env.sh

而后持续启动 pulsar ./pulsar standalone


说我 zookeeper 有启动 2181 端口了。

是的,我的云主机是启动了一个 zookeeper。那我把我本人的启动的 zookeeper 停掉。

进到你装置 zookeeper 的目录中,执行以下进行的命令即可。

./zkServer.sh stop


再次启动 pulsar ./pulsar standalone

如果能看到以上日志,阐明 pulsar 启动胜利了!

启动后,会始终卡主前台过程,如果须要敞开 pulsar,间接 ctrl+c 即可。

二、生产与生产

2.1 模仿开启消费者监听数据

./pulsar-client consume my-topic -s "first-subscription"

2.2 模仿开启生产者生产数据

./pulsar-client produce my-topic --messages "hello-pulsar"

2.3 消费者胜利接管音讯

三、小结

Pulsar 的给我的感觉就是开箱即用,Pulsar 还帮咱们内置了 zookeeper,咱们至此都没有装置 zookeeper,期间我还停掉了本人的 zookeeper,这也正阐明了 Pulsar 内置了 zookeeper,与我本人的 zookeeper 端口产生了抵触。

通过 jps 命令,也能够发现 Pulsar 帮咱们启动了 zookeeper,有 QuorumPeerMain 过程。

Pulsar 与 Kafka 的单机模式搭建,一比照,毫无疑问,Pulsar 好简洁啊,Kafka 与 Zookeeper 一堆繁琐参数的配置。

好了,下一篇咱们来搭建 Pulsar 的分布式建集群环境。咱们下期再见~

退出移动版