tree: b21561bd34ad499ecd43b0785779e189739c919f [path history] [tgz]
  1. main/
  2. test/
  3. README.md
src/README.md

Pulsar manager backend

Pulsar manager backend is a supplement and improvement to Pulsar broker.

  • Handle complex query requests
  • Route requests (add, delete, update) to brokers
  • Support multi broker, dynamic change environment

Supported configurations of backend

NameDefaultDescription
server.port7750Port of backend service
pulsar-manager.accountpulsarLogin account
pulsar-manager.passwordpulsarLogin password
redirect.hostlocalhostIP address of front-end service
redirect.port9527Port of front-end service
insert.stats.interval30000msTime interval for collecting statistical information
clear.stats.interval300000msTime interval for cleaning statistics

How to set parameters when starting back-end services

java -jar ./build/libs/pulsar-manager.jar --redirect.host=http://localhost --redirect.port=9527 insert.stats.interval=600000

Use custom databases

If you have a large amount of data, you can use a custom database. The following is an example of PostgreSQL.

  1. Initialize database and table structures using file.

  2. Modify the configuration file and add PostgreSQL configuration

spring.datasource.driver-class-name=org.postgresql.Driver
spring.datasource.url=jdbc:postgresql://127.0.0.1:5432/pulsar_manager
spring.datasource.username=postgres
spring.datasource.password=postgres
  1. Compile to generate a new executable jar package
./gradlew -x build -x test

Enable JWT Auth

If you want to turn on JWT authentication, configure the following parameters:

  • backend.jwt.token token for the superuser. You need to configure this parameter during cluster initialization.
  • jwt.broker.token.mode Two modes of generating token, SECRET and PRIVATE.
  • jwt.broker.public.key Configure this option if you are using the PRIVATE mode.
  • jwt.broker.private.key Configure this option if you are using the PRIVATE mode.
  • jwt.broker.secret.key Configure this option if you are using the SECRET mode.

For more information, see Apache Pulsar

  • Method 1: Use command-line tool
java -jar ./build/libs/pulsar-manager.jar --redirect.host=http://localhost --redirect.port=9527 insert.stats.interval=600000 --backend.jwt.token=token --jwt.broker.token.mode=PRIVATE --jwt.broker.private.key=file:///path/broker-private.key --jwt.broker.public.key=file:///path/broker-public.key
  • Method 2. Configure the application.properties file
backend.jwt.token=token

jwt.broker.token.mode=PRIVATE
jwt.broker.public.key=file:///path/broker-public.key
jwt.broker.private.key=file:///path/broker-private.key

or 
jwt.broker.token.mode=SECRET
jwt.broker.secret.key=file:///path/broker-secret.key