zoukankan      html  css  js  c++  java
  • 【转载】Apache Kafka监控之Kafka Web Console

    http://www.iteblog.com/archives/1084

    Kafka Web Console是一款开源的系统,源码的地址在https://github.com/claudemamo/kafka-web-console中。Kafka Web Console也是用Scala语言编写的Java web程序用于监控Apache Kafka。这个系统的功能和KafkaOffsetMonitor很类似,但是我们从源码角度来看,这款系统实现比KafkaOffsetMonitor要复杂很多,而且编译配置比KafkaOffsetMonitor较麻烦。
      要想运行这套系统我们需要的先行条件为:

    1. Play Framework 2.2.x
    2. Apache Kafka 0.8.x
    3. Zookeeper 3.3.3 or 3.3.4

      同样,我们从https://github.com/claudemamo/kafka-web-console上面将源码下载下来,然后用sbt进行编译,在编译前我们需要做如下的修改:
      1、Kafka Web Console默认用的数据库是H2,它支持以下几种数据库:

    H2 (default)
    PostgreSql
    Oracle
    DB2
    MySQL
    Apache Derby
    Microsoft SQL Server
    为了方便,我们可以使用Mysql数据库,只要做如下修改即可,找到 conf/application.conf文件,并修改如下
    将这个
    db.default.driver=org.h2.Driver
    db.default.url="jdbc:h2:file:play"
    # db.default.user=sa
    # db.default.password=""
    
    
    修改成
    db.default.driver=com.mysql.jdbc.Driver
    db.default.url="jdbc:mysql://localhost:3306/kafkamonitor"
    db.default.user=iteblog
    db.default.pass=wyp
    

      我们还需要修改build.sbt,加入对Mysql的依赖:

    "mysql" % "mysql-connector-java" % "5.1.31"
    

      2、执行conf/evolutions/default/bak目录下面的1.sql、2.sql和3.sql三个文件。需要注意的是,这三个sql文件不能直接运行,有语法错误,需要做一些修改。
    上面的注意事项弄完之后,我们就可以编译下载过来的源码:

    # sbt package
    编译的过程比较慢,有些依赖包下载速度非常地慢,请耐心等待。
    在编译的过程中,可能会出现有些依赖包无法下载,如下错误:
    [warn] module not found: com.typesafe.play#sbt-plugin;2.2.1
    [warn] ==== typesafe-ivy-releases: tried
    [warn] http://repo.typesafe.com/typesafe/ivy-releases/
    com.typesafe.play/sbt-plugin/scala_2.9.2/sbt_0.12/2.2.1/ivys/ivy.xml
    [warn] ==== sbt-plugin-releases: tried
    [warn] http://scalasbt.artifactoryonline.com/scalasbt/sbt-plugin-releases/
    com.typesafe.play/sbt-plugin/scala_2.9.2/sbt_0.12/2.2.1/ivys/ivy.xml
    [warn] ==== local: tried
    [warn] /home/iteblog/.ivy2/local/com.typesafe.play/
    sbt-plugin/scala_2.9.2/sbt_0.12/2.2.1/ivys/ivy.xml
    [warn] ==== Typesafe repository: tried
    [warn] http://repo.typesafe.com/typesafe/releases/com/
    typesafe/play/sbt-plugin_2.9.2_0.12/2.2.1/sbt-plugin-2.2.1.pom
    [warn] ==== public: tried
    [warn] http://repo1.maven.org/maven2/com/typesafe/play/
    sbt-plugin_2.9.2_0.12/2.2.1/sbt-plugin-2.2.1.pom
    [warn] ::::::::::::::::::::::::::::::::::::::::::::::
    
    ==== local: tried
    
    /home/iteblog/.ivy2/local/org.scala-sbt/collections/0.13.0/jars/collections.jar
    
    ::::::::::::::::::::::::::::::::::::::::::::::
    
    :: FAILED DOWNLOADS ::
    
    :: ^ see resolution messages for details ^ ::
    
    ::::::::::::::::::::::::::::::::::::::::::::::
    
    :: org.scala-sbt#collections;0.13.0!collections.jar
    
    ::::::::::::::::::::::::::::::::::::::::::::::
    

      

    我们可以手动地下载相关依赖,并放到类似/home/iteblog/.ivy2/local/org.scala-sbt/collections/0.13.0/jars/目录下面。然后再编译就可以了。

      最后,我们可以通过下面命令启动Kafka Web Console监控系统:

    # sbt run
    

      并可以在http://localhost:9000查看。下面是一张效果图





  • 相关阅读:
    洛谷P1057传球游戏(逆向递推递归+记忆化)
    洛谷P1433吃奶酪(正向暴力递归,回溯更新)
    洛谷P1434滑雪(逆向图的遍历搜索递归+记忆化,最长路问题)
    洛谷P1192台阶问题(逆向递推递归dfs+记忆化)
    洛谷p1025数的划分(正向暴力递归,数学排列与组合问题)
    洛谷P1141 01迷宫(图的遍历搜素递归dfs或bfs,连痛块回溯更新问题,记忆化或者并查集根结点)
    Git 版本更新--Windows
    plop-templates自动新建项目文件
    前端-随机生成测试数据-mockjs
    cookie、seseionStorage、localStorage的区别
  • 原文地址:https://www.cnblogs.com/bluejoe/p/5119056.html
Copyright © 2011-2022 走看看