首页 > 其他分享 >Pulsar 入门实战(4)--命令行使用

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

时间:2024-09-28 15:47:54浏览次数:7  
标签: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

相关文章

  • Idea的常用快捷键,会这几个够了!
    本篇文章仅说几个常用的快捷键,包括Win系统与Mac系统两个版本,常用的用熟悉了,就能极大提高效率了。这几个快捷键值得反复练习,Java刚上手的同学建议收藏!1、全文查找:Ctrl+Shift+F(Win)、Command+Shift+F(Mac)在整个项目中查找特定字符串,有时候碰到某个方法的名字、变量的名字,翻找代......
  • [场景设计]断点续传
    要实现大文件的断点续传,通常的实现方式是将文件分块上传(切割文件)并记录每个块的状态,以便在中断后可以从上次上传完成的块继续上传。你可以基于以下几个步骤来实现这个功能,主要涉及字节流操作、文件分块、状态记录和续传的逻辑。1.文件分块将大文件切割成多个小块进行上传,这样在......
  • redis 管道 批量处理 transmit multiple commands to the Redis server in one tran
    Redispipelining|Docshttps://redis.io/docs/latest/develop/use/pipelining/RedispipeliningHowtooptimizeround-triptimesbybatchingRediscommandsRedispipeliningisatechniqueforimprovingperformancebyissuingmultiplecommandsatoncewithou......
  • PARTVI-Oracle数据库管理与开发-数据库管理员的概念
    18.数据库管理员的概念18.1.数据库管理员的职责数据库管理员(DBA)的主要责任是使企业数据对其用户可用。DBA必须与开发人员紧密合作,确保他们的应用程序有效地使用数据库,并与系统管理员合作,确保物理资源充足且使用高效。OracleDBA负责了解Oracle数据库架构以及数据库的工作原理......
  • [Java基础]IO
    在Java中,IO(输入输出)操作是指对数据的读写操作,通常涉及文件、网络、控制台等。Java提供了丰富的IO类和接口,主要分为两大类:字节流和字符流。它们的主要区别如下:1.字节流(ByteStream)字节流用于处理原始二进制数据,通常适合于处理所有类型的文件,包括文本文件、图片、音频、......
  • [Java并发]线程的并行等待
    在Java中,线程的并行等待(即等待多个线程并行执行完毕)通常可以通过以下几种方式来实现。我们要确保多个线程能够并行执行,并在所有线程执行完毕后再继续后续的操作。这种场景通常可以用在并发任务的协调中。以下是几种常见的实现方式:1.使用Thread.join()方法join()方法是最直......
  • WPF FlowDocument List ListItem Paragraph BlockUIContainer Table TableRowGr
    <Windowx:Class="WpfApp419.MainWindow"xmlns="http://schemas.microsoft.com/winfx/2006/xaml/presentation"xmlns:x="http://schemas.microsoft.com/winfx/2006/xaml"xmlns:d="http://schemas.microsoft......
  • 7、集成SpringSecurity安全框架---定义统一的响应对象类
    自定义/***@Description:TODO:定义统一的响应对象类*/@Data@AllArgsConstructor@NoArgsConstructorpublicclassResultVO<T>implementsSerializable{privatestaticfinallongserialVersionUID=-2548645345465031121L;privateIntegercode;pr......
  • javascript 数组对象解构
    传统的写法不好记忆,书写麻烦,此时可以使用结构赋值的方法让代码更加简洁。数组结构是将数组中的单元值快速批量赋值给一系列变量的简介语法。变量的顺序对应数组单元值位置一次进行赋值操作。如下:应用一:交换两个变量Js前面有那种情况需要加分号。(不加分号解析器认为和上......
  • 8、集成SpringSecurity安全框架---登录请求放行配置
    @ConfigurationpublicclassSecurityConfig{//创建BCryptPasswordEncoder注入容器,密码加密@BeanpublicPasswordEncoderpasswordEncoder(){returnnewBCryptPasswordEncoder();}//登录时调用一次AuthenticationManager.authenticat......