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实现数据生产/消费
03_Apache Pulsar的Local与分布式集群构建Pulsar的分布式集群模式Pulsar的分布式集群模式构建启动测试