Pulsar

安装

在linux下载pulsar安装包 wget https://archive.apache.org/dist/pulsar/pulsar-2.8.1/apache-pulsar-2.8.1-bin.tar.gz
解压缩 tar xvfz apache-pulsar-2.8.1-bin.tar.gz
启动 ./bin/pulsar standalone
后台启动 nohup ./bin/pulsar standalone &

报错 10:36:21.059 [main] ERROR org.apache.pulsar.zookeeper.LocalBookkeeperEnsemble - Exception while instantiating ZooKeeper
java.net.BindException: 地址已在使用

检查端口 2181

netstat -tunlp 检查目前所用的所有端口
netstat -tunlp | grep 2181 检查2181端口是否使用

fuser -v -n tcp 2181 检查占用2181端口的程序及进程
kill -9 杀死对应的pid，再重新启动pulsar即可

./pulsar-client produce my-topic --messages "-----hello pulsar-------" # 生产一条消息
./pulsar-client consume my-topic -s "-----hello pulsar-------" # 消费一条消息

修改IP和端口，让其它机器访问

./pulsar-client produce my-topic --messages “-----hello pulsar-------”

Policies not found for fl-tenant/fl-algorithm namespace
org.apache.pulsar.client.api.PulsarClientException$BrokerMetadataException: Policies not found for fl-tenant/fl-algorithm namespace

./pulsar-admin tenants create fl-tenant
./pulsar-admin namespaces create fl-tenant/fl-algorithm

Pulsar 的管理可以通过LIC命令行，REST api 、JAVA api管理
以下介绍使用LIC命令行 (pulsar2.4.2上测试)
1 租户
查看有哪些租户(public 是系统默认的租户)
$ pulsar-admin tenants list
创建租户
$ pulsar-admin tenants create my-tenant
删除租户
$ pulsar-admin tenants delete my-tenant

2 命名空间
查看指定租户下边的命名空间
$ pulsar-admin namespaces list test-tenant
创建指定租户命名空间
$ pulsar-admin namespaces create test-tenant/test-namespace
删除指定租户命名空间
$ pulsar-admin namespaces delete test-tenant/test-namespace