Pulsarctl

Apache Pulsar 的 CLI
授权协议 Apache
开发语言 Google Go
所属分类 程序开发、 其他开发相关
软件类型 开源软件
地区 不详
投 递 者 充小云
操作系统 跨平台
开源组织
适用人群 未知
 软件概览

Pulsarctl是StreamNative为Apache Pulsar开发的命令行界面(CLI)。

功能与特性:

Pulsarctl是pulsar-admin的替代工具,用于管理Apache Pulsar中的客户端。 Pulsarctl是基于Pulsar REST API,用Go语言编写的。它为Go开发人员提供API接口和用户友好的命令,从而使其更易于与Pulsar Broker进行交互。

与pulsar-admin相比,Pulsarctl更加用户友好:

  • Pulsarctl统一分区主题和主题命令,并提供清晰详细的输出;
  • 在Pulsarctl中,所有与订阅相关的命令都分组在订阅命令中,而在pulsar-admin中,所有与订阅相关的命令都用作主题的子命令,使用不便;
  • Pulsarctl改进了特殊字符的使用,而在pulsar-admin中,要求用户在shell中输入json-string,用法复杂。

使用方法

Pulsarctl有两种使用方式:

  1. 在Go中使用并与Pulsar Broker进行交互。Admin API是由Go开发的。
  2. 在命令行中将其用作pulsar-admin。

示例

使用Pulsarctl Admin API代码示例:

config := &pulsar.Config{
		WebServiceURL: “http://localhost:8080”,
		HTTPClient:    http.DefaultClient,

		// If the server enable the TLSAuth
		// Auth: auth.NewAuthenticationTLS()

		// If the server enable the TokenAuth
		// TokenAuth: auth.NewAuthenticationToken()
	}
	// the default NewPulsarClient will use v2 APIs. If you need to request other version APIs,
	// you can specified the API version like this:
	// admin := cmdutils.NewPulsarClientWithAPIVersion(pulsar.V2)
	admin, err := pulsar.New(config)
	if err != nil {
		// handle the err
		return
	}

	// more APIs, you can find them in the pkg/pulsar/admin.go
	// You can find all the method in the pkg/pulsar
	clusters, err := admin.Clusters().List()
	if err != nil {
		// handle the error
	}

	// handle the result
	fmt.Println(clusters)

更多操作及与pulsar-admin的对比,请参考软件文档。

 相关资料
  • 当尝试测试Java客户端的方法时,我收到了一个关于RepoService saveAndFlush方法的NPE。 然后进行我期望得到一个异常的测试 然后,在来自ClientX的这条线路上使用NPE进行测试失败 有人知道为什么serviceX或repoX是空的/得到NPE吗?

  • 问题内容: 我创建了一个基本的CellTable并用一些数据填充了它。现在,我想向每一行添加一个clickHandler,但是我不确定如何执行此操作。我已经为整个表格创建了一个clickEvent,但是我希望每一行都有一个。 我可以做一些类似于为每一行添加clickEvent的事情吗? 问题答案: CellTable内置了对处理单击事件的支持。您可以添加单击行时将被调用的a。它将在事件中接收许多项

  • 本文向大家介绍clipboard在vue中的使用的方法示例,包括了clipboard在vue中的使用的方法示例的使用技巧和注意事项,需要的朋友参考一下 简介 页面中用 clipboard 可以进行复制粘贴,clipboard能将内容直接写入剪切板 安装 使用方法一 使用方法二 以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持呐喊教程。

  • 大家好,我对Spring和angular很陌生,我正在构建一个Spring java服务器和一个angular客户机。基本上,我希望客户机能够捕捉从服务器抛出的异常。我定义了一个CustomexEption.java类,并在服务器端有一个CustomRestExceptionHandler.java。现在,我不确定应该在服务器中的哪里抛出异常,以便客户机捕捉。 我的客户端登录组件如下所示:

  • 在前面一章,我这么艰苦地写了click listener的目的就是更好的在这一章中进行开发。然而现在是时候把你学到的东西用到实践中去了。我们从ForecastListAdapter中删除了listener接口,然后使用lambda代替: public class ForecastListAdapter(val weekForecast: ForecastList,

  • 我是 Angular 2(以及一般的 Angular...)的新手,并且发现它非常吸引人。我正在使用 Angular CLI 来生成和服务项目。它似乎运行良好——尽管对于我的小学习项目来说,它产生的比我需要的要多—— 我注意到它为项目中的每个 Angular 元素(组件、服务、管道等)生成。我已经搜索了周围,但没有找到这些文件的用途的解释。 这些构建文件在使用时通常是隐藏的吗?我想知道,因为我想更

  • 本文向大家介绍vue-cli创建的项目中的gitHooks原理解析,包括了vue-cli创建的项目中的gitHooks原理解析的使用技巧和注意事项,需要的朋友参考一下 前言 在使用 vue create my-app 创建项目的时候,Vue 会自动帮我们做好一些预配置,你可以不使用它,但是一旦需要的时候,突然发现,咦~原来它已经帮我做好准备工作了,只需要按自己的需求配置一下就可以了,就会觉得 vu

  • 在kotlin函数返回之前放置语句会崩溃。StackTrace: 去掉冒犯行,一个成功的输出: Java: 可能我只是没有正确地打印到控制台。