Pulsar 的 Geo-Replication 测试

以下测试基于 pulsar:2.8.0 standalone 模式
详细信息参考官方教程:https://pulsar.apache.org/docs/en/2.8.0/administration-geo/

环境搭建

准备两台机器,假设未 ip1 与 ip2,执行如下:

环境搭建

# 在 ip1 机器上执行:
docker apachepulsar/pulsar:/pulsar/conf .
# 修改 standalone.conf, 设置 clusterName=cluster1

# 启动容器
docker run -itd -p 8080:8080 -p 6650:6650 -v conf:/pulsar/conf apachepulsar/pulsar bin/pulsar standalone

以上步骤在 ip2 上做一次,但是名字不要冲突,假设clusterName为 cluster2

配置同步

# 在 ip1 机器上执行:
# 创建集群
bin/pulsar-admin clusters create \
--broker-url pulsar://ip2:6650 \
--url http://ip2:8080 \
cluster2

# 创建租户
bin/pulsar-admin tenants create my-tenant \
  --admin-roles my-admin-role \
  --allowed-clusters cluster1,cluster2

# 创建 namespace
bin/pulsar-admin namespaces create my-tenant/my-namespace

# 配置 namespace 集群权限
bin/pulsar-admin namespaces set-clusters my-tenant/my-namespace \
  --clusters cluster69,cluster52

上述步骤在机器 ip2 执行一遍,注意做对应修改

测试

此时两个standalone 就完成了集群的同步。在任一个机器上创建 my-tenant/my-namespace 下的 topic,与 topic 里的消息(订阅状态同步需要手动使能)都会被同步到另一个机器。

上一篇:Photoshop逼真的绿色叶子制作方法


下一篇:蓝桥杯学习记录||1236. 递增三元组