Skip to content

streamnative/pulsarctl

This branch is 45 commits ahead of, 97 commits behind master.

Folders and files

NameName
Last commit message
Last commit date

Latest commit

2a16cf7 · Oct 8, 2024
Oct 8, 2024
Nov 2, 2022
Feb 16, 2023
Apr 28, 2024
Jun 2, 2022
May 22, 2024
Sep 25, 2023
Aug 6, 2021
Nov 25, 2021
Oct 16, 2019
Oct 16, 2019
Jul 7, 2019
Oct 7, 2021
Dec 29, 2021
Jul 29, 2020
Jan 18, 2020
Jan 31, 2024
Jan 31, 2024
Jan 14, 2020
Jan 4, 2022
Sep 24, 2019
Jun 14, 2021
Aug 3, 2020

Repository files navigation

Language LICENSE GoDoc

Pulsarctl

A CLI tool for the Apache Pulsar project.

Available Releases

Version Reference
0.5.0 Command Reference
0.4.1 Command Reference
0.4.0 Command Reference
0.3.0 Command Reference
0.2.0 Command Reference
0.1.0 Command Reference

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:

  1. Download the package from here.
  2. Add the pulsarctl directory to your system PATH.
  3. Type pulsarctl -h at CMD to verify that pulsarctl is work.

As project dependency

Use go get to install pulsarctl as dependency on your project:

go get github.com/streamnative/pulsarctl@master

Note: We will not release v0.y.z tags, so you need to use master branch code.

Build pulsarctl from codes

Prerequisite

  • Go 1.11 +

    If you have not installed Go, install it according to the installation instruction.

    Since the go mod package management tool is used in this project, Go 1.11 or higher version is required.

Steps

  1. Download codes.

    1. Clone the project from GitHub to your local.

      git clone https://github.com/streamnative/pulsarctl.git
    2. Use go mod to get the dependencies needed for the project.

      go mod download

      After entering the go mod download command, if some libs can not be downloaded, then you can download them by referring to the proxy provided by GOPROXY.io.

  2. Build pulsarctl

    make pulsarctl

    If you want to print version of pulsarctl, you can use follow commands:

    bin/pulsarctl --version
    

    Output:

    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