implement kafka client

kafkademo\.classpath
.........\.project
.........\.settings\org.eclipse.core.resources.prefs
.........\bin\com\pa\cp\passport\info\kafka\consumer\AbstractConsumer.class
.........\...\...\..\..\........\....\.....\........\impl\TestTopicConsumer.class
.........\...\...\..\..\........\....\.....\........\KafkaConsumerConfig.class
.........\...\...\..\..\........\....\.....\........\KafkaConsumerGroupConfig.class
.........\...\...\..\..\........\....\.....\........\KafkaConsumerListener.class
.........\...\...\..\..\........\....\.....\........\KafkaCousumerMain.class
.........\...\...\..\..\........\....\.....\........\test\ConsumerDemo.class
.........\...\...\..\..\........\....\.....\........\....\ConsumerMsgTask.class
.........\...\...\..\..\........\....\.....\........\....\PartitionerDemo.class
.........\...\...\..\..\........\....\.....\........\....\ProducerDemo.class
.........\...\...\..\..\........\....\.....\producer\KafkaPartitioner.class
.........\...\...\..\..\........\....\.....\........\KafkaProducer.class
.........\...\kafka_consumer.xml
.........\...\kafka_producer.properties
.........\lib\dom4j-1.6.1.jar
.........\...\jopt-simple-3.2.jar
.........\...\kafka-clients-0.8.2-beta.jar
.........\...\kafka_2.11-0.8.2-beta.jar
.........\...\log4j-1.2.16.jar
.........\...\lz4-1.2.0.jar
.........\...\metrics-core-2.2.0.jar
.........\...\scala-library-2.11.1.jar
.........\...\scala-parser-combinators_2.11-1.0.2.jar
.........\...\scala-xml_2.11-1.0.2.jar
.........\...\slf4j-api-1.7.6.jar
.........\...\slf4j-log4j12-1.6.1.jar
.........\...\snappy-java-1.1.1.3.jar
.........\...\zkclient-0.3.jar
.........\...\zookeeper-3.4.6.jar
.........\src\com\pa\cp\passport\info\kafka\consumer\AbstractConsumer.java
.........\...\...\..\..\........\....\.....\........\impl\TestTopicConsumer.java
.........\...\...\..\..\........\....\.....\........\KafkaConsumerConfig.java
.........\...\...\..\..\........\....\.....\........\KafkaConsumerGroupConfig.java
.........\...\...\..\..\........\....\.....\........\KafkaConsumerListener.java
.........\...\...\..\..\........\....\.....\........\KafkaCousumerMain.java
.........\...\...\..\..\........\....\.....\........\test\ConsumerDemo.java
.........\...\...\..\..\........\....\.....\........\....\ConsumerMsgTask.java
.........\...\...\..\..\........\....\.....\........\....\PartitionerDemo.java
.........\...\...\..\..\........\....\.....\........\....\ProducerDemo.java
.........\...\...\..\..\........\....\.....\producer\KafkaPartitioner.java
.........\...\...\..\..\........\....\.....\........\KafkaProducer.java
.........\...\kafka_consumer.xml
.........\...\kafka_producer.properties
.........\bin\com\pa\cp\passport\info\kafka\consumer\impl
.........\...\...\..\..\........\....\.....\........\test
.........\src\com\pa\cp\passport\info\kafka\consumer\impl
.........\...\...\..\..\........\....\.....\........\test
.........\bin\com\pa\cp\passport\info\kafka\consumer
.........\...\...\..\..\........\....\.....\producer
.........\src\com\pa\cp\passport\info\kafka\consumer
.........\...\...\..\..\........\....\.....\producer
.........\bin\com\pa\cp\passport\info\kafka
.........\src\com\pa\cp\passport\info\kafka
.........\bin\com\pa\cp\passport\info
.........\src\com\pa\cp\passport\info
.........\bin\com\pa\cp\passport
.........\src\com\pa\cp\passport
.........\bin\com\pa\cp
.........\src\com\pa\cp
.........\bin\com\pa
.........\src\com\pa
.........\bin\com
.........\src\com
.........\.settings
.........\bin
.........\lib
.........\src
kafkademo

• We are an exchange download platform that only provides communication channels. The downloaded content comes from the internet. Except for download issues, please Google on your own.
• The downloaded content is provided for members to upload. If it unintentionally infringes on your copyright, please contact us.
• Please use Winrar for decompression tools
• If download fail, Try it againg or Feedback to us.
• If downloaded content did not match the introduction, Feedback to us，Confirm and will be refund.
• Before downloading, you can inquire through the uploaded person information

Nothing．