Kafka监控程序

Kafka监控程序附带测试代码

package org.kafka;

import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Properties;

import kafka.consumer.ConsumerConfig;
import kafka.consumer.ConsumerIterator;
import kafka.consumer.KafkaStream;
import kafka.javaapi.consumer.ConsumerConnector;

/**
 * @author leicui bourne_cui@163.com
 */
public class KafkaConsumer extends Thread
{
    private final ConsumerConnector consumer;
    private final String topic;

    public KafkaConsumer（String topic）
    {
        consumer = kafka.consumer.Consumer.createJavaConsumerConnector（
                createConsumerConfig（））;
        this.topic = topic;
    }

    private static ConsumerConfig createConsumerConfig（）
    {
        Properties props = new Properties（）;
        props.put（“zookeeper.connect“ KafkaProperties.zkConnect）;
        props.put（“group.id“ KafkaProperties.groupId）;
        props.put（“zookeeper.session.timeout.ms“ “40000“）;
        props.put（“zookeeper.sync.time.ms“ “200“）;
        props.put（“auto.commit.interval.ms“ “1000“）;
        return new ConsumerConfig（props）;
    }

    @Override
    public void run（） {
        Map topicCountMap = new HashMap（）;
        topicCountMap.put（topic new Integer（1））;
        Map>> consumerMap = consumer.createMessageStreams（topicCountMap）;
        KafkaStream stream = consumerMap.get（topic）.get（0）;
        ConsumerIterator it = stream.iterator（）;
        while （it.hasNext（）） {
            System.out.println（“receive:“ + new String（it.next（）.message（）））;
            try {
                sleep（3000）;
            } catch （InterruptedException e） {
                e.printStackTrace（）;
            }
        }
    }
}

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----
     目录           0  2017-05-07 21:00  .idea\
     文件           9  2017-05-07 20:51  .idea\.name
     文件        1194  2017-05-07 20:51  .idea\compiler.xml
     目录           0  2017-05-07 20:51  .idea\copyright\
     文件          76  2017-05-07 20:51  .idea\copyright\profiles_settings.xml
     目录           0  2017-05-07 20:52  .idea\libraries\
     文件         489  2017-05-07 20:52  .idea\libraries\Maven__com_101tec_zkclient_0_3.xml
     文件         563  2017-05-07 20:52  .idea\libraries\Maven__com_yammer_metrics_metrics_core_2_2_0.xml
     文件         516  2017-05-07 20:52  .idea\libraries\Maven__io_netty_netty_3_7_0_Final.xml
     文件         469  2017-05-07 20:52  .idea\libraries\Maven__jline_jline_0_9_94.xml
     文件         462  2017-05-07 20:51  .idea\libraries\Maven__junit_junit_3_8_1.xml
     文件         469  2017-05-07 20:52  .idea\libraries\Maven__log4j_log4j_1_2_16.xml
     文件         488  2017-05-07 20:52  .idea\libraries\Maven__net_jpountz_lz4_lz4_1_2_0.xml
     文件         542  2017-05-07 20:52  .idea\libraries\Maven__net_sf_jopt_simple_jopt_simple_3_2.xml
     文件         555  2017-05-07 20:52  .idea\libraries\Maven__org_apache_kafka_kafka_2_10_0_8_2_2.xml
     文件         576  2017-05-07 20:52  .idea\libraries\Maven__org_apache_kafka_kafka_clients_0_8_2_2.xml
     文件         550  2017-05-07 20:52  .idea\libraries\Maven__org_apache_zookeeper_zookeeper_3_4_6.xml
     文件         561  2017-05-07 20:52  .idea\libraries\Maven__org_scala_lang_scala_library_2_10_4.xml
     文件         506  2017-05-07 20:52  .idea\libraries\Maven__org_slf4j_slf4j_api_1_7_6.xml
     文件         534  2017-05-07 20:52  .idea\libraries\Maven__org_slf4j_slf4j_log4j12_1_6_1.xml
     文件         566  2017-05-07 20:52  .idea\libraries\Maven__org_xerial_snappy_snappy_java_1_1_1_7.xml
     文件        1058  2017-05-07 20:53  .idea\misc.xml
     文件         258  2017-05-07 20:51  .idea\modules.xml
     文件        8792  2017-05-07 21:00  .idea\uiDesigner.xml
     文件         164  2017-05-07 20:51  .idea\vcs.xml
     文件       31654  2017-05-08 23:43  .idea\workspace.xml
     文件    52937155  2017-05-08 23:24  KafkaOffsetMonitor-assembly-0.2.1.jar
     文件        2181  2017-05-07 20:52  kafkatest.iml
     文件       44032  2017-05-08 23:45  offsetapp.db
     文件        1182  2017-05-07 20:52  pom.xml
     目录           0  2017-05-07 19:46  src\
............此处省略21个文件信息