1.4.Apache Pulsar的可视化监控管理

1.4.1.Apache Pulsar的可视化监控部署

第一步：下载Pulsar-Manager

https://archive.apache.org/dist/pulsar/pulsar-manager/pulsar-manager-0.2.0/apache-pulsar-manager-0.2.0-bin.tar.gz

https://www.apache.org/dyn/mirrors/mirrors.cgi?action=download&filename=pulsar/pulsar-manager/pulsar-manager-0.3.0/apache-pulsar-manager-0.3.0-bin.tar.gz

第二步：上传到服务器，并解压

cd /export/software 
rz 上传 apache-pulsar-manager-0.2.0-bin.tar.gz 
解压操作: 
tar -zxf apache-pulsar-manager-0.2.0-bin.tar.gz -C /export/server/ 
cd /export/server/pulsar-manager 
接着再次解压: 
tar -xvf pulsar-manager.tar

第三步：拷贝dist包到pulsar-manager目录下并更名为ui

cd /export/server/pulsar-manager/pulsar-manager
cp -r ../dist ui

在这里插入图片描述
修改application.properties、bkvm.conf，将其中的localhost和127.0.0.1修改成node1

第四步：启动Pulsar

[root@node1 pulsar-manager]# cd /export/server/pulsar-manager/pulsar-manager
[root@node1 pulsar-manager]# nohup bin/pulsar-manager >> pulsar-manager.log 2>&1 &
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/export/server/pulsar-manager/pulsar-manager/lib/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/export/server/pulsar-manager/pulsar-manager/lib/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/export/server/pulsar-manager/pulsar-manager/lib/log4j-slf4j-impl-2.10.0.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
SLF4J: Actual binding is of type [ch.qos.logback.classic.util.ContextSelectorStaticBinder]
2022-08-21 00:23:39.961  INFO 6968 --- [           main] s.c.a.AnnotationConfigApplicationContext : Refreshing org.springframework.context.annotation.AnnotationConfigApplicationContext@17f7cd29: startup date [Sun Aug 21 00:23:39 CST 2022]; root of context hierarchy
2022-08-21 00:23:40.955  INFO 6968 --- [           main] f.a.AutowiredAnnotationBeanPostProcessor : JSR-330 'javax.inject.Inject' annotation found and supported for autowiring
2022-08-21 00:23:41.545  INFO 6968 --- [           main] trationDelegate$BeanPostProcessorChecker : Bean 'configurationPropertiesRebinderAutoConfiguration' of type [org.springframework.cloud.autoconfigure.ConfigurationPropertiesRebinderAutoConfiguration$$EnhancerBySpringCGLIB$$a73d9f96] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)

  .   ____          _            __ _ _
 /\\ / ___'_ __ _ _(_)_ __  __ _ \ \ \ \
( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \
 \\/  ___)| |_)| | | | | || (_| |  ) ) ) )
  '  |____| .__|_| |_|_| |_\__, | / / / /
 =========|_|==============|___/=/_/_/_/
 :: Spring Boot ::        (v2.0.2.RELEASE)

2022-08-21 00:23:42.947  INFO 6968 --- [           main] o.a.p.manager.PulsarManagerApplication   : No active profile set, falling back to default profiles: default
2022-08-21 00:23:43.080  INFO 6968 --- [           main] ConfigServletWebServerApplicationContext : Refreshing org.springframework.boot.web.servlet.context.AnnotationConfigServletWebServerApplicationContext@29a0cdb: startup date [Sun Aug 21 00:23:43 CST 2022]; parent: org.springframework.context.annotation.AnnotationConfigApplicationContext@17f7cd29
2022-08-21 00:23:45.400  INFO 6968 --- [           main] o.s.b.f.s.DefaultListableBeanFactory     : Overriding bean definition for bean 'dataSource' with a different definition: replacing [Root bean: class [null]; scope=; abstract=false; lazyInit=false; autowireMode=3; dependencyCheck=0; autowireCandidate=true; primary=false; 
xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx
xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx
xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx
2022-08-21 00:24:12.153  INFO 6968 --- [           main] o.s.b.w.embedded.tomcat.TomcatWebServer  : Tomcat started on port(s): 7750 (http) with context path ''
2022-08-21 00:24:12.210  INFO 6968 --- [           main] o.a.p.manager.PulsarManagerApplication   : Started PulsarManagerApplication in 33.906 seconds (JVM running for 35.345)
2022-08-21 00:24:12.397  INFO 6968 --- [pool-3-thread-1] o.a.p.m.s.i.EnvironmentCacheServiceImpl  : Successfully reloaded environments : []
2022-08-21 00:24:42.285  INFO 6968 --- [pool-3-thread-1] o.a.p.m.s.impl.BrokerStatsServiceImpl    : Start clearing stats from broker
2022-08-21 00:25:12.327  INFO 6968 --- [pool-3-thread-1] o.a.p.m.s.impl.BrokerStatsServiceImpl    : Start clearing stats from broker
2022-08-21 00:25:12.347  INFO 6968 --- [pool-3-thread-1] herddb.server.ServerSideConnectionPeer   : client jvm-local connected as sa
2022-08-21 00:25:12.420  INFO 6968 --- [pool-3-thread-1] o.a.p.m.s.i.EnvironmentCacheServiceImpl  : Successfully reloaded environments : []
2022-08-21 00:25:42.403  INFO 6968 --- [pool-3-thread-1] o.a.p.m.s.impl.BrokerStatsServiceImpl    : Start clearing stats from broker

第五步：初始化超级用户密码
其中用户名是：pulsar 密码是：pulsar

CSRF_TOKEN=$(curl http://node1:7750/pulsar-manager/csrf-token)

curl \
-H "X-XSRF-TOKEN: $CSRF_TOKEN" \
-H "Cookie: XSRF-TOKEN=$CSRF_TOKEN;" \
-H 'Content-Type: application/json' \
-X PUT http://node1:7750/pulsar-manager/users/superuser \
-d '{"name": "pulsar", "password": "pulsar", "description": "test", "email": "makj@test.org"}'