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個文件信息