04_Apache Pulsar的可视化监控管理Apache Pulsar的可视化监控部署

Posted 涂作权的博客

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了04_Apache Pulsar的可视化监控管理Apache Pulsar的可视化监控部署相关的知识,希望对你有一定的参考价值。

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

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"'
  • 第六步:访问Pulsar UI
    http://node1:7750/ui/index.html 或者访问:http://192.168.106.103:7750/ui/index.html

    用户名:pulsar
    密码:pulsar

1.4.2.Apache Pulsar的可视化监控基本使用

第一步:点击new Environment构建新环境 连接pulsar

第二步:点击pulsar_cluster

以上是关于04_Apache Pulsar的可视化监控管理Apache Pulsar的可视化监控部署的主要内容,如果未能解决你的问题,请参考以下文章

06.Apache Pulsar的JAVA API相关使用操作,基于Pulsar实现Topic的构建操作,使用JAVA如何管理租户/namespace/Topic,基于Pulsar实现数据生产/消费

Pulsar 介绍

在 Apache Pulsar 中授予命名空间权限

03_Apache Pulsar的Local与分布式集群构建Pulsar的分布式集群模式Pulsar的分布式集群模式构建启动测试

从 apache pulsar 主题中检索所有过去的消息

TiDB 联手 Apache Pulsar,释放大数据潜能