Pulsar 入门实战(4)--命令行使用

标签：default 入门 -- topics admin pulsar test Pulsar public

本文主要介绍 Pulsar 的命令行使用，相关的环境及软件信息如下：CentOS 7.9.2009、Pulsar 3.3.0、Java 17.0.10。

1、环境配置

在 conf/client.conf 中配置 Pulsar 相关地址：

webServiceUrl=http://10.49.196.30:8080,10.49.196.31:8080,10.49.196.32:8080
brokerServiceUrl=pulsar://10.49.196.30:6650,10.49.196.31:6650,10.49.196.32:6650

2、命令使用

各命令可以使用 -h 或 --help 查看使用方法。

2.1、pulsar-admin

2.1.1、broker-stats

查看 broker 的统计信息。

A、查看监控指标信息

pulsar-admin broker-stats monitoring-metrics

2.1.2、brokes

broker 相关命令。

A、查看集群的活动 broker

pulsar-admin brokers list pulsar-cluster-1

B、查看 leader broker 信息

pulsar-admin brokers leader-broker

C、健康检查

pulsar-admin brokers healthcheck

D、查看 broker 版本

pulsar-admin brokers version

2.1.3、bookies

bookie 相关命令。

A、列出所有 bookie

pulsar-admin bookies list-bookies

2.1.4、clusters

集群相关命令。

A、获取集群配置信息

pulsar-admin clusters get pulsar-cluster-1

B、列出所有集群

pulsar-admin clusters list

2.1.5、namespaces

命名空间相关的命令。

A、列出租户的命名空间

pulsar-admin namespaces list public

B、列出命名空间的主题

pulsar-admin namespaces topics public/default

C、创建命名空间

pulsar-admin namespaces create public/test #public租户下创建test命名空间

D、删除命名空间

pulsar-admin namespaces delete public/test

2.1.6、topics

A、列出命名空间的主题

pulsar-admin topics list public/default

B、列出命名空间的分区主题

pulsar-admin topics list-partitioned-topics public/default

C、创建非分区主题

pulsar-admin topics create persistent://public/default/test

D、创建分区主题

pulsar-admin topics create-partitioned-topic persistent://public/default/ptest -p 2

E、删除主题

pulsar-admin topics delete persistent://public/default/test

F、删除分区主题

pulsar-admin topics delete-partitioned-topic persistent://public/default/ptest

G、清理主题

pulsar-admin topics truncate persistent://public/default/test

此操作将会将所有游标移动到主题末尾，并删除所有不活动的账本。

H、从 broker 内存中卸载主题

pulsar-admin topics unload persistent://public/default/test

I、列出主题的订阅

pulsar-admin topics subscriptions persistent://public/default/test

J、创建订阅

pulsar-admin topics create-subscription -s my-subscription persistent://public/default/test

K、删除订阅

pulsar-admin topics unsubscribe -s my-subscription persistent://public/default/test

L、获取主题的统计信息

pulsar-admin topics stats persistent://public/default/test

M、获取主题的内部统计信息

pulsar-admin topics stats-internal persistent://public/default/test

N、获取主题的元数据信息

pulsar-admin topics info-internal persistent://public/default/test

O、获取分区主题的统计信息

pulsar-admin topics partitioned-stats  persistent://public/default/ptest

P、获取分区主题的内部统计信息

pulsar-admin topics partitioned-stats-internal persistent://public/default/ptest

2.1.7、tenants

租户相关命令。

A、列出租户

pulsar-admin tenants list

B、获取租户配置

pulsar-admin tenants get public

C、创建租户

pulsar-admin tenants create test-tenant

D、删除租户

pulsar-admin tenants delete test-tenant

2.2、pulsar

2.2.1、broker

前台启动 broker。

2.2.2、bookie

前台启动 bookie。

2.2.3、zookeeper

前台启动 zookeeper。

2.2.4、standalone

前台单机模式启动 pulsar。

2.3、pulsar-client

2.3.1、produce

发送消息。

pulsar-client produce \
    persistent://public/default/test \
    -n 1 \
    -m "Hello Pulsar"

2.3.2、consume

消费消息。

pulsar-client consume \
    persistent://public/default/test \
    -n 100 \
    -s "consumer-test" \
    -t "Exclusive"

2.4、pulsar-daemon

后台启动或停止相应的服务，语法：

pulsar-daemon (start|stop|restart) <command> <args...>

2.4.1、broker

pulsar-daemon start broker #启动 broker
pulsar-daemon stop broker #停止 broker

2.4.2、bookie

pulsar-daemon start bookie #启动 bookie
pulsar-daemon stop bookie #停止 bookie

2.4.3、zookeeper

pulsar-daemon start zookeeper #启动 zookeeper
pulsar-daemon stop zookeeper #停止 zookeeper

2.4.4、standalone

pulsar-daemon start standalone #启动单机 pulsar
pulsar-daemon stop standalone #停止单机 pulsar

 

标签：default,入门,--,topics,admin,pulsar,test,Pulsar,public
From： https://www.cnblogs.com/wuyongyin/p/18324997