linkedin開源的kafka-monitor安裝文檔

linkedin開源的kafka-monitor安裝文檔##

linkedin 開源的kafka-monitor的安裝使用可以參考官方的readme；流程介紹的已經比較清楚，但是還是有一些地方需要修正。讓大家可以少填一些坑。

1. 前提條件###

   Kafka Monitor 需要 Gradle 2.0 或者更高版本. 編譯和執行都需要在java8環境下。

2. 下載源碼###

   $ git clone https://github.com/linkedin/kafka-monitor.git $ cd kafka-monitor $ ./gradlew jar
   如果編譯過程中下載類庫速度緩慢，可以改為國內庫。

   cd kakfa-monitor;vi build.gradle

      repositories {
    	//mavenCentral()
    	maven { url 'http://10.150.144.28/nexus/content/groups/public' }
    }
   

3. 運行kafka-monitor的測試服務並指定Config File
   $ ./bin/kafka-monitor-start.sh config/kafka-monitor.properties
   運行會報錯：

    Exception in thread "main" java.lang.RuntimeException: Can not find valid partition number for topic test. Please verify that the topic has been created. Ideally the partition number should be a multiple of number of brokers in the cluster.
    at com.linkedin.kmf.services.ProduceService.<init>(ProduceService.java:75)
    at com.linkedin.kmf.tests.BasicEndToEndTest.<init>(BasicEndToEndTest.java:54)
    at com.linkedin.kmf.tests.BasicEndToEndTest.main(BasicEndToEndTest.java:230)
   

   發現 zookeeper.connect需要指定kafka的根路徑，如下：

      "end-to-end": {
        "class.name": "com.linkedin.kmf.tests.BasicEndToEndTest",
        "topic": "kmf-topic",
       	"zookeeper.connect": "192.168.108.50:2181/kafka",
        "bootstrap.servers": "192.168.108.50:9092",
        "produce.record.delay.ms": 100,
        "produce.producer.props": {
          "client.id": "kmf-client-id"
        },
        "consume.consumer.props": {
          "group.id": "kmf-group-id"
        }
    }
   

4. 運行 BasicEndToEndTest監控kafka集群

這里的zookeeper也需要指定根路徑。

$ ./bin/end-to-end-test.sh --topic test --broker-list localhost:9092 --zookeeper localhost:2181/kafka

4. 通過UI實時的獲取度量的值

   在瀏覽器打開 localhost:8000/index.html

   我們可以編輯 webapp/index.html 輕松實現添加一個度量的或者刪除一個。

5. 使用http 請求查詢其他度量值

   curl localhost:8778/jolokia/read/kmf.services:type=produce-metrics,name=*/produce-availability-avg
   

   我們可以根據JMX metric 的object-name和attribute-name 查詢其他的JMX metric。

6. 運行代碼格式檢查checkstyle

./gradlew checkstyleMain checkstyleTest

5. 使用IDE構建項目

./gradlew idea
./gradlew eclipse

更多信息參考kafka-monitor的官網：

• 源碼下載
• wiki