Apache Pulsar常用命令

Apache Pulsar常用命令

Apache Pulsar常用命令

租户相关命令

获取租户列表创建租户获取配置更新配置删除用户 Pulsar 名称空间

在指定的租户下创建名称空间获取所有的名称空间列表删除名称空间 Pulsar的topic相关 *** 作

Pulsar Topic(主题) 相关 *** 作_基础 *** 作创建Topic

方式一: 创建一个没有分区的topic方式二: 创建一个有分区的topic 列出当前某个名称空间下的所有Topic

更新Topic *** 作- 删除Topic *** 作

删除没有分区的topic:删除有分区的topic Pulsar Function 轻量级计算框架

构建function启动function产看function状态

租户相关命令

获取租户列表

bin/pulsar-admin tenants list

创建租户

bin/pulsar-admin tenants create my-tenant

创建租户时候，指定角色

bin/pulsar-admin tenants create my-tenant --admin-roles role1,role2,role3
bin/pulsar-admin tenants create my-tenant  -r role1

获取配置

 bin/pulsar-admin tenants get my-tenant
# 效果
[pulsar@pulsar03 pulsar-2.4.0]$ bin/pulsar-admin tenants get my-tenant11
{
  "adminRoles" : [ "role1", "role2", "role3" ],
  "allowedClusters" : [ "pulsar-cluster" ]
}
[pulsar@pulsar03 pulsar-2.4.0]$ 

更新配置

bin/pulsar-admin tenants update my-tenant11

删除用户

注意: 在删除的时候, 如果库下已经有名称空间, 是无法删除的,需要先删除名称空间

bin/pulsar-admin tenants delete my-tenant11

Pulsar 名称空间 在指定的租户下创建名称空间

bin/pulsar-admin namespaces create my-tenant/my-namespace

获取所有的名称空间列表

bin/pulsar-admin namespaces list my-tenant

删除名称空间

bin/pulsar-admin namespaces delete my-tenant/my-nn1

Pulsar的topic相关 *** 作 Pulsar Topic(主题) 相关 *** 作_基础 *** 作 创建Topic 方式一: 创建一个没有分区的topic

bin/pulsar-admin topics create persistent://my-tenant/my-namespace/my-topic 

方式二: 创建一个有分区的topic

bin/pulsar-admin topics create-partitioned-topic persistent://my-tenant/my-namespace/my-topic11 --partitions 4 

注意: 不管是有分区还是没有分区, 创建topic后,如果没有任何 *** 作, 60s后pulsar会认为此topic是不活动的, 会 自动进行删除, 以避免生成垃圾数据

相关配置: Brokerdeleteinactivetopicsenabenabled : 默认值为true 表示是否启动自动删除 BrokerDeleteInactiveTopicsFrequencySeconds: 默认为60s 表示检测未活动的时间

列出当前某个名称空间下的所有Topic

 bin/pulsar-admin topics list my-tenant/my-namespace

[pulsar@pulsar03 pulsar-2.4.0]$  bin/pulsar-admin topics list my-tenant/my-namespace
persistent://my-tenant/my-namespace/my-topic
[pulsar@pulsar03 pulsar-2.4.0]$

更新Topic *** 作

bin/pulsar-admin topics update-partitioned-topic persistent://my-tenant/my-namespace/my-topic --partitions 8 

- 删除Topic *** 作 删除没有分区的topic:

bin/pulsar-admin topics delete persistent://my-tenant/my-namespace/my-topic 

删除有分区的topic

bin/pulsar-admin topics delete-partitioned-topic persistent://my-tenant/my-namespace/my-topic

Pulsar Function 轻量级计算框架 构建function

cd /export/server/pulsar_2.8.1/ 
bin/pulsar-admin functions create  
--jar functions/pulsar_base-1.0-SNAPSHOT.jar 
 --classname com.itheima.functions.WordCountFunction 
  --inputs persistent://public/default/wd_input  
  --output persistent://public/default/wd_output  
  --tenant public  
  --namespace default 
   --name wordcount

启动function

trigger 触发启动, 并向函数发送数据测试 
bin/pulsar-admin functions trigger --name wordcount --trigger-value "2021/10/10 15/30/30"

停止函数

bin/pulsar-admin functions stop --tenant public --namespace default --name appStrFunction

启动函数

bin/pulsar-admin functions start --tenant public --namespace default --name appStrFunction

删除函数

bin/pulsar-admin functions delete --tenant public --namespace default --name appStrFunction

产看function状态

bin/pulsar-admin functions status --tenant public --namespace default --name appStrFunction

[pulsar@pulsar03 pulsar-2.4.0]$  bin/pulsar-admin functions status --tenant jiang  --namespace jiang_0118  --name xml-jiang-220118
{
  "numInstances" : 1,
  "numRunning" : 1,
  "instances" : [ {
    "instanceId" : 0,
    "status" : {
      "running" : true,
      "error" : "",
      "numRestarts" : 3,
      "numReceived" : 0,
      "numSuccessfullyProcessed" : 0,
      "numUserExceptions" : 0,
      "latestUserExceptions" : [ ],
      "numSystemExceptions" : 0,
      "latestSystemExceptions" : [ ],
      "averageLatency" : 0.0,
      "lastInvocationTime" : 0,
      "workerId" : "c-pulsar-cluster-fw-10.21.171.60-8080"
    }
  } ]
}
[pulsar@pulsar03 pulsar-2.4.0]$