资讯

精准传达 • 有效沟通

从品牌网站建设到网络营销策划，从策略到执行的一站式服务

网站建设 >

查看其它板块

Pulsar怎么部署到Kubernetes

Pulsar怎么部署到Kubernetes，针对这个问题，这篇文章详细介绍了相对应的分析和解答，希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。

成都创新互联公司专注于惠东网站建设服务及定制，我们拥有丰富的企业做网站经验。 热诚为您提供惠东营销型网站建设，惠东网站制作、惠东网页设计、惠东网站官网定制、微信平台小程序开发服务，打造惠东网络公司原创品牌,更为您提供惠东网站排名全网营销落地服务。

前提条件

  • Kubernetes server 1.14.0+

  • kubectl 1.14.0+

  • Helm 3.0+

 
Tip

对于接下来的步骤，步骤 2 与步骤 3 适用于 开发者，步骤 4 和 步骤 5 适用于 管理员。

步骤 0：准备一个 Kubernetes 集群

在安装 Pulsar Helm chart 之前，你必须创建一个 Kubernetes 集群。 你可以按照 指示 来准备一个Kubernetes集群。

We use Minikube in this quick start guide. 要准备一个 Kubernetes 集群，请遵循以下步骤：

  1. 在 Minikube 上创建一个 Kubernetes 集群。

    minikube start --memory=8192 --cpus=4 --kubernetes-version=

    可以是  Minikube 安装程序支持的任意 Kubernetes 版本 比如 v1.16.1。

  2. 设置 kubectl 来使用 Minikube。

    kubectl config use-context minikube

  3. 若要在 Minikube 上使用与本地 Kubernetes 集群的 Kubernetes Dashboard，输入以下的命令：

    minikube dashboard

    这条命令会自动用你的浏览器打开一个网页。

步骤 1：安装 Pulsar Helm chart

  1. 添加 Pulsar Helm 仓库。

    helm repo add apache https://pulsar.apache.org/charts

    helm repo update

  2. 克隆 Pulsar Helm chart 的仓库。

    git clone https://github.com/apache/pulsar-helm-chartcd pulsar-helm-chart

  3. 运行脚本 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

  4. 使用 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 \
        --set initialize=true \
        --namespace pulsar \
        pulsar-mini apache/pulsar
     

  5. 检查所有 pod 的状态。

    kubectl get pods -n pulsar

    如果所有 pod 都成功启动，你会看到 STATUS 变为 Running 或 Completed。

    输出

    NAME                                         READY   STATUS      RESTARTS   AGE
pulsar-mini-bookie-0                         1/1     Running     0          9m27s
pulsar-mini-bookie-init-5gphs                0/1     Completed   0          9m27s
pulsar-mini-broker-0                         1/1     Running     0          9m27s
pulsar-mini-grafana-6b7bcc64c7-4tkxd         1/1     Running     0          9m27s
pulsar-mini-prometheus-5fcf5dd84c-w8mgz      1/1     Running     0          9m27s
pulsar-mini-proxy-0                          1/1     Running     0          9m27s
pulsar-mini-pulsar-init-t7cqt                0/1     Completed   0          9m27s
pulsar-mini-pulsar-manager-9bcbb4d9f-htpcs   1/1     Running     0          9m27s
pulsar-mini-toolset-0                        1/1     Running     0          9m27s
pulsar-mini-zookeeper-0                      1/1     Running     0          9m27s

  6. 检查命名空间 pulsar 下所有服务的状态。

    kubectl get services -n pulsar

    输出

    NAME                         TYPE           CLUSTER-IP       EXTERNAL-IP   PORT(S)                       AGE
pulsar-mini-bookie           ClusterIP      None                     3181/TCP,8000/TCP             11m
pulsar-mini-broker           ClusterIP      None                     8080/TCP,6650/TCP             11m
pulsar-mini-grafana          LoadBalancer   10.106.141.246        3000:31905/TCP                11m
pulsar-mini-prometheus       ClusterIP      None                     9090/TCP                      11m
pulsar-mini-proxy            LoadBalancer   10.97.240.109         80:32305/TCP,6650:31816/TCP   11m
pulsar-mini-pulsar-manager   LoadBalancer   10.103.192.175        9527:30190/TCP                11m
pulsar-mini-toolset          ClusterIP      None                                             11m
pulsar-mini-zookeeper        ClusterIP      None                     2888/TCP,3888/TCP,2181/TCP    11m

步骤 2：使用 pulsar-admin 来创建 Pulsar 租户/命名空间/主题

pulsar-admin 是 Pulsar 的 CLI（命令行客户端） 工具。 这一步中，你可以使用 pulsar-admin 来创建资源，包括租户、命名空间和主题。

  1. 进入 toolset 容器。

    kubectl exec -it -n pulsar pulsar-mini-toolset-0 -- /bin/bash

  2. 在 toolset 容器里，创建一个名为 apache 的租户。

    bin/pulsar-admin tenants create apache

    然后你可以列出所有租户，来查看租户是否创建成功。

    bin/pulsar-admin tenants list

    你应该能看到类似如下的输出： 租户 apache 已经被成功地创建了。

    "apache""public""pulsar"

  3. 在 toolset 容器里，在租户 apache 下创建一个名为 pulsar 的命名空间。

    bin/pulsar-admin namespaces create apache/pulsar

    然后你可以列出租户 apache 的所有命名空间，来查看命名空间是否创建成功。

    bin/pulsar-admin namespaces list apache

    你应该能看到类似如下的输出： 命名空间 apache/pulsar 已经被成功地创建了。

    "apache/pulsar"

  4. 在 toolset 容器里，在命名空间 apache/pulsar 下创建一个包含 4 个分区的主题 test-topic。

    bin/pulsar-admin topics create-partitioned-topic apache/pulsar/test-topic -p 4

  5. 在 toolset 容器里，列出命名空间 apache/pulsar 中的所有分区主题。

    bin/pulsar-admin topics list-partitioned-topics apache/pulsar

    然后你可以看见命名空间 apache/pulsar 下的所有分区主题。

    "persistent://apache/pulsar/test-topic"

步骤 3：使用 Pulsar 客户端生产和消费消息

你可以使用 Pulsar 客户端来创建生产者与消费者并用于生产和消费消息。

默认地，Pulsar Helm chart 会通过 Kubernetes LoadBalancer 将 Pulsar 集群暴露出来。 在 Minikube 中，你可以使用如下命令来检查代理服务。

kubectl get services -n pulsar | grep pulsar-mini-proxy

你将看到类似如下的输出：

pulsar-mini-proxy            LoadBalancer   10.97.240.109         80:32305/TCP,6650:31816/TCP   28m

这个输出显示了 Pulsar 集群的二进制端口 和 HTTP 端口都映射到了哪个 node 端口上。 80: 后面的端口是 HTTP 端口，而 6650: 后面的端口是二进制端口。

然后你就可以找到 IP 地址并通过运行以下命令来对外暴露你的 Minikube 服务器。

minikube service pulsar-mini-proxy -n pulsar

输出

|-----------|-------------------|-------------|-------------------------|
| NAMESPACE |       NAME        | TARGET PORT |           URL           |
|-----------|-------------------|-------------|-------------------------|
| pulsar    | pulsar-mini-proxy | http/80     | http://172.17.0.4:32305 |
|           |                   | pulsar/6650 | http://172.17.0.4:31816 |
|-----------|-------------------|-------------|-------------------------|
???? pulsar-mini-proxy 服务的起始通道。
|-----------|-------------------|-------------|------------------------|
| NAMESPACE |       NAME        | TARGET PORT |          URL           |
|-----------|-------------------|-------------|------------------------|
| pulsar    | pulsar-mini-proxy |             | http://127.0.0.1:61853 |
|           |                   |             | http://127.0.0.1:61854 |
|-----------|-------------------|-------------|------------------------|

此时，你可以获得连接到你的 Pulsar 客户端的服务 URL。 下面是一些 URL 示例：

webServiceUrl=http://127.0.0.1:61853/brokerServiceUrl=pulsar://127.0.0.1:61854/

然后你可以继续如下步骤：

  1. 从 下载页面 下载 Apache Pulsar tarball。

  2. 基于你的下载文件解压 tarball。

    tar -xf .tar.gz

  3. 暴露 PULSAR_HOME。

    (1) 输入已解压的下载文件的目录。

    (2) 将 PULSAR_HOME 暴露为环境变量。

     ```bash
 export PULSAR_HOME=$(pwd)
 ```

  4. 配置 Pulsar 客户端。

    在 ${PULSAR_HOME}/conf/client.conf 文件中，用你从上面步骤中获得的服务 URL 来替换掉 webServiceUrl 与 brokerServiceUrl。

  5. 创建订阅以消耗来自 apache/pulsar/test-tope 的消息。

    bin/pulsar-client consume -s sub apache/pulsar/test-topic  -n 0

  6. 打开一个新的终端。 在新终端中，创建一个生产者并向 test-topic 主题发送10条消息。

    bin/pulsar-client produce apache/pulsar/test-topic  -m "---------hello apache pulsar-------" -n 10

  7. 验证结果。

    • 对于生产者而言

      输出

      消息已被成功生产。

      18:15:15.489 [main] INFO  org.apache.pulsar.client.cli.PulsarClientTool - 10 messages successfully produced

    • 对于消费者而言

      输出

      同时，你可以收到如下的消息。

      ----- got message -----
---------hello apache pulsar-------
----- got message -----
---------hello apache pulsar-------
----- got message -----
---------hello apache pulsar-------
----- got message -----
---------hello apache pulsar-------
----- got message -----
---------hello apache pulsar-------
----- got message -----
---------hello apache pulsar-------
----- got message -----
---------hello apache pulsar-------
----- got message -----
---------hello apache pulsar-------
----- got message -----
---------hello apache pulsar-------
----- got message -----
---------hello apache pulsar-------

步骤 4：使用 Pulsar Manager 来管理集群

Pulsar Manager 是一个基于网络 GUI 的管理工具，用于管理和监测Pulsar。

  1. 默认情况下， Pulsar Manager 作为一个独立的 LoadBalancer 暴露给外界。 你可以使用以下命令打开 Pulsar Manager 界面：

    minikube service -n pulsar pulsar-mini-pulsar-manager

  2. Pulsar Manager UI 将会在你的浏览器中打开。 你可以使用用户名 pulsar 和密码 pulsar 来登录进 Pulsar Manager。

  3. 在 Pulsar Manager UI 中，你可以创建一个环境。

    • 点击左上角的 New Environment 按钮。

    • 在弹窗中的 Environment Name 一栏里入 pulsar-mini。

    • 在弹窗中的 Service URL 一栏里输入 http://pulsar-mini-broker:8080。

    • 点击弹窗中的 Confirm 按钮。

  4. 成功创建环境后，你将被重定向到新环境的 租户 页面。 然后你可以使用 Pulsar Manager 来创建 租户、命名空间 和 主题。

步骤 5：使用 Prometheus 和 Grafana 来监控集群

Grafana 是一个开源的可视化工具，用于将时间序列数据直观地可视化为仪表板。

  1. 默认情况下， Grafana 作为一个独立的 LoadBalancer 暴露给外界。 你可以使用以下命令打开 Grafana 界面：

    minikube service pulsar-mini-grafana -n pulsar

  2. Grafana UI 会在你的浏览器中打开。 你可以使用用户名 pulsar 和密码 pulsar 来登录进 Grafana仪表板。

  3. 你可以查看 Pulsar 集群的不同组件的仪表板。

关于Pulsar怎么部署到Kubernetes问题的解答就分享到这里了，希望以上内容可以对大家有一定的帮助，如果你还有很多疑惑没有解开，可以关注创新互联行业资讯频道了解更多相关知识。


当前题目：Pulsar怎么部署到Kubernetes
浏览路径：http://www.cdkjz.cn/article/jcjohc.html
返回首页 了解更多建站资讯

相关资讯

多年建站经验

多一份参考，总有益处

联系快上网，免费获得专属《策划方案》及报价

咨询相关问题或预约面谈，可以通过以下方式与我们联系

大客户专线   成都：13518219792   座机：028-86922220

在线咨询 提交需求
友情链接 交换友情链接
眉山主机托管成都网站推广成都食品包装设计IDC机房托管乐山服务器托管成都免费建网站成都企业注册服务兴宏源活动板房香港机房服务器托管手机网站设计

成都网站建设公司地址：成都市青羊区太升南路288号锦天国际A座10层 建设咨询028-86922220

成都快上网科技有限公司-四川网站建设设计公司 | 蜀ICP备19037934号 Copyright 2020,ALL Rights Reserved cdkjz.cn | 成都网站建设 | © Copyright 2020版权所有.

专家团队为您提供成都网站建设,成都网站设计,成都品牌网站设计,成都营销型网站制作等服务,成都建网站就找快上网！ | 成都网站建设哪家好？ | 网站建设地图