pulsar是流式处理和队列的合体。
他可以做到百分百不丢数据,kafka无法做到
puslar对日志进行分块,避免拷贝大块数据
puslar是无状态的,非常适合云原生
多租户,不像rabbitmq 消息一多性能下降 ,不得不多装几个集群
全球最大puslar集群有80多个租户,230万个topic
参考文档
Get started in Kubernetes · Apache Pulsar
系统
ubuntu 20 8G 内存 8核cpu
1. 安装minikube
minikube start | minikube (k8s.io)
curl -LO https://storage.googleapis.com/minikube/releases/latest/minikube-linux-amd64 sudo install minikube-linux-amd64 /usr/local/bin/minikube
2. 安装kubectl 和helm
3.启动minikube
minikube start --memory=8192 --cpus=4
4.设置kubectl
kubectl config use-context minikube
5.查看dashboard
minikube dashboard
6.安装pulsar
添加 Pulsar Helm 仓库。
helm repo add apache https://pulsar.apache.org/charts
helm repo update
克隆 Pulsar Helm chart 的仓库。
gitclonehttps://github.com/apache/pulsar-helm-chartcdpulsar-helm-chart
运行脚本 prepare_helm_release.sh 来创建安装 Apache Pulsar Helm chart 所需的 secrets。 用户名 pulsar 与密码 pulsar 可用于登录 Grafana dashboard 与 Pulsar Manager。
./scripts/pulsar/prepare_helm_release.sh \
-n pulsar \
-k pulsar-mini \
-c
使用 Pulsar Helm chart 来将一个 Pulsar 集群安装至 Kubernetes。
NOTE
You need to specify --set initialize=true when installing Pulsar the first time. This command installs and starts Apache Pulsar.
helm install \ --values examples/values-minikube.yaml \ --setinitialize=true\ --namespace pulsar \ pulsar-mini apache/pulsar
检查所有 pod 的状态。
kubectl get pods -n pulsar
如果所有 pod 都成功启动,你会看到 STATUS 变为 Running 或 Completed。
7.成功截屏
网友评论