hadoop►kafka►kafka web console

kafka web console

kafka web console

  1. Java install

    1
    2
    3
    4
    5
    6
    7
    8
    [root@localhost app]# tar xzf jdk-8u111-linux-x64.tar.gz
    [root@localhost app]# mv jdk1.8.0_111 /mnt/app/java
    [root@localhost app]# echo 'JAVA_HOME=/mnt/app/java' | tee /etc/profile.d/java.sh
    [root@localhost app]# echo 'JRE_HOME=${JAVA_HOME}/jre' | tee -a /etc/profile.d/java.sh
    [root@localhost app]# echo 'CLASSPATH=.:${JAVA_HOME}/lib:${JRE_HOME}/lib' | tee -a /etc/profile.d/java.sh
    [root@localhost app]# echo 'export PATH=${JAVA_HOME}/bin:$PATH' | tee -a /etc/profile.d/java.sh
    [root@localhost app]# source  /etc/profile
    [root@localhost app]# java -version

  2. sbt install

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    [root@localhost app]# cat >/etc/yum.repos.d/bintray-sbt-rpm.repo<< eof
    #bintray--sbt-rpm - packages by  from Bintray
    [bintray--sbt-rpm]
    name=bintray--sbt-rpm
    baseurl=https://sbt.bintray.com/rpm
    gpgcheck=0
    repo_gpgcheck=0
    enabled=1
    EOF
    [root@localhost app]# yum -y install sbt

  3. scala install

    1
    2
    3
    4
    5
    6
    7
    [root@localhost app]# wget https://downloads.lightbend.com/scala/2.11.6/scala-2.11.6.tgz
    [root@localhost app]# tar xzf scala-2.11.6.tgz
    [root@localhost app]# mv scala-2.11.6 /mnt/app/scala
    [root@localhost app]# cat >/etc/profile.d/scala.sh <<EOF
    export SCALA_HOME=/mnt/app/scala
    export PATH=\$PATH:\$SCALA_HOME/bin
    EOF

  4. kafka-web-console install

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    [root@localhost app]# wget https://github.com/claudemamo/kafka-web-console/archive/master.zip
    [root@localhost app]# unzip master
    [root@localhost app]# cd kafka-web-console-master
    [root@localhost kafka-web-console-master]# sbt package
    [root@localhost kafka-web-console-master]# sbt dist
    [root@localhost kafka-web-console-master]# sbt run   //可以直接运行

    [root@localhost kafka-web-console-master]# mkdir -p /mnt/app/kafka-web-console
    [root@localhost kafka-web-console-master]# unzip target/universal/kafka-web-console-2.1.0-SNAPSHOT.zip /mnt/app/kafka-web-console
    [root@localhost kafka-web-console-master]# cd /mnt/app/kafka-web-console
    [root@localhost kafka-web-console]# bin/kafka-web-console -DapplyEvolutions.default=true
    [root@localhost kafka-web-console]# bin/kafka-web-console -Dhttp.port=9001 >/dev/null 2>&1 &

  5. 通过web浏览器进行查看