聊聊 Pulsar: 在 Linux 环境上搭建 Pulsar

简介: 聊聊 Pulsar: 在 Linux 环境上搭建 Pulsar

一、环境准备

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 的分布式建集群环境。我们下期再见~



欢迎大家关注我的公众号【老周聊架构】,Java后端主流技术栈的原理、源码分析、架构以及各种互联网高并发、高性能、高可用的解决方案。

相关文章
|
15天前
|
Oracle Java 关系型数据库
Linux环境安装配置JDK11
Linux环境安装配置JDK11
47 0
|
17天前
|
人工智能 Unix Linux
Linux的学习之路:1、发展史与编译环境的搭建
Linux的学习之路:1、发展史与编译环境的搭建
15 0
|
2月前
|
JSON Kubernetes Linux
Linux环境签发CA证书和K8s需要的证书
Linux环境签发CA证书和K8s需要的证书
29 0
|
2月前
|
关系型数据库 MySQL Java
Window环境linux环境安装skywalking
Window环境linux环境安装skywalking
35 0
|
2月前
|
监控 安全 Shell
防止员工泄密的措施:在Linux环境下使用Bash脚本实现日志监控
在Linux环境下,为防止员工泄密,本文提出使用Bash脚本进行日志监控。脚本会定期检查系统日志文件,搜索敏感关键词(如"password"、"confidential"、"secret"),并将匹配项记录到临时日志文件。当检测到可疑活动时,脚本通过curl自动将数据POST到公司内部网站进行分析处理,增强信息安全防护。
106 0
|
28天前
|
存储 算法 Linux
【实战项目】网络编程:在Linux环境下基于opencv和socket的人脸识别系统--C++实现
【实战项目】网络编程:在Linux环境下基于opencv和socket的人脸识别系统--C++实现
56 7
|
1天前
|
关系型数据库 MySQL Linux
在Linux系统上实现高效安装与部署环境的全方位指南
在Linux系统上实现高效安装与部署环境的全方位指南
|
3天前
|
运维 NoSQL Linux
linux环境收集core文件步骤
请注意,生成core文件可能会占用磁盘空间,因此应谨慎使用。一旦完成故障排查,建议将相关的core文件删除以释放磁盘空间。
30 5
|
4天前
|
运维 NoSQL Linux
linux环境收集core文件步骤
请注意,生成core文件可能会占用磁盘空间,因此应谨慎使用。一旦完成故障排查,建议将相关的core文件删除以释放磁盘空间。
18 4
|
13天前
|
编解码 Linux
FFmpeg开发笔记(十二)Linux环境给FFmpeg集成libopus和libvpx
在《FFmpeg开发实战》一书中,介绍了如何在Linux环境下为FFmpeg集成libopus和libvpx,以支持WebM格式的Opus和VP8/VP9编码。首先,下载并安装libopus。接着,下载并安装libvpx。最后,在FFmpeg源码目录下,重新配置FFmpeg,启用libopus和libvpx,编译并安装。通过`ffmpeg -version`检查版本信息,确认libopus和libvpx已启用。
FFmpeg开发笔记(十二)Linux环境给FFmpeg集成libopus和libvpx