pulsarctl
pulsarctl copied to clipboard
a CLI for Apache Pulsar written in Go
Pulsarctl
A CLI tool for the Apache Pulsar project.
Install pulsarctl
Mac operation system
Use homebrew to install pulsarctl on the Mac operation system.
brew tap streamnative/streamnative
brew install pulsarctl
Linux operation system
Use this command to install pulsarctl on the Linux operation system.
sh -c "$(curl -fsSL https://raw.githubusercontent.com/streamnative/pulsarctl/master/install.sh)"
Windows operation system
To install pulsarctl on the Windows operation system, follow these steps:
- Download the package from here.
- Add the
pulsarctldirectory to your system PATH. - Type
pulsarctl -hat CMD to verify thatpulsarctlis work.
As project dependency
Use go get to install the pulsarctl as dependency on your project:
# Using master branch
go get github.com/streamnative/pulsarctl@master
# Or using v2.10.1.3 tag
go get github.com/streamnative/[email protected]
# Or using v2.9.3.3 tag
go get github.com/streamnative/[email protected]
Note: We will not release v0.y.z tags, so you need to specify the branch or tag.
Build pulsarctl from codes
Prerequisite
-
Go 1.11 +
If you have not installed Go, install it according to the installation instruction.
Since the
go modpackage management tool is used in this project, Go 1.11 or higher version is required.
Steps
-
Download codes.
-
Clone the project from GitHub to your local.
git clone https://github.com/streamnative/pulsarctl.git -
Use
go modto get the dependencies needed for the project.go mod downloadAfter entering the
go mod downloadcommand, if some libs can not be downloaded, then you can download them by referring to the proxy provided by GOPROXY.io.
-
-
Build pulsarctl
make pulsarctlIf you want to print version of
pulsarctl, you can use follow commands:bin/pulsarctl --versionOutput:
Release Version: v2.8.0.3 Git Commit Hash: add1e586e8d56fcc1cbd2fe94ed75b10d6c54672 Git Branch: HEAD UTC Build Time: 2021-06-26 06:39:16 Go Version: go version go1.16.3 darwin/amd64
Enable Auto-Completion
If you want to enable autocompletion in shell, see enable_completion.
Use contexts
If you want to cache information of multiple clusters, and can switch between multiple clusters, see How to use pulsarctl context.
Project Status
The following is an incomplete list of features that are not yet implemented:
Functions
- localrun
Sources
- localrun
- available-sources
- reload
Sinks
- localrun
- available-sources
- reload
Schemas
- extract
Namespaces
- delete-bookie-affinity-group
- get-bookie-affinity-group
- set-bookie-affinity-group
Bookies
- racks-placement
- get-bookie-rack
- delete-bookie-rack
- set-bookie-rack
Different With Java Pulsar Admin
We move the subscription commands from the topics to the subscriptions in pulsarctl.
| pulsar-admin | pulsarctl |
|---|---|
| bin/pulsar-admin topics create-subscription | pulsarctl subscription create |
| bin/pulsar-admin topics unsubscribe | pulsarctl subscription delete |
| bin/pulsar-admin topics skip | pulsarctl subscription skip |
| bin/pulsar-admin topics expire-messages | pulsarctl subscription expire |
| bin/pulsar-admin topics peek-messages | pulsarctl subscription peek |
| bin/pulsar-admin topics reset-cursor | pulsarctl subscription seek |
| bin/pulsar-admin topics subscriptions | pulsarctl subscription list |
Contribute
Contributions are welcomed and greatly appreciated. For more information about how to submit a patch and the contribution workflow, see CONTRIBUTING.md.
License
Licensed under the Apache License Version 2.0: http://www.apache.org/licenses/LICENSE-2.0