Description: Kafka is a high throughput distributed publish subscribe messaging system, which can handle all of the action stream data in the consumer scale. This action (web browsing, search, and other users actions) is a key factor in many social functions on modern networks. These data are usually resolved by processing log and log aggregation due to the requirement of throughput. For log data and offline analysis system like Hadoop, it is a feasible solution to the limit of real time processing. The purpose of the Kafka is to provide real-time information through the Hadoop s parallel loading mechanism, which is also to provide real-time consumption through the cluster.
To Search:
File list (Check if you may need any files):
KafkaTest\.classpath
.........\.project
.........\.settings\org.eclipse.jdt.core.prefs
.........\bin\com\kafkatest\consumer\ConsumerSample.class
.........\...\...\.........\producer\ProducerSample.class
.........\lib\jopt-simple-3.2.jar
.........\...\jsp-api.jar
.........\...\kafka-clients-0.8.2.1.jar
.........\...\kafka_2.10-0.8.1.2.2.0.0-2041.jar
.........\...\kafka_2.10-0.8.2.1-test.jar
.........\...\kafka_2.10-0.8.2.1.jar
.........\...\log4j-1.2.16.jar
.........\...\lz4-1.2.0.jar
.........\...\metrics-core-2.2.0.jar
.........\...\scala-library-2.10.4.jar
.........\...\servlet-api.jar
.........\...\slf4j-api-1.7.6.jar
.........\...\slf4j-log4j12-1.6.1.jar
.........\...\snappy-java-1.1.1.6.jar
.........\...\zkclient-0.3.jar
.........\...\zookeeper-3.4.6.jar
.........\src\com\kafkatest\consumer\ConsumerSample.java
.........\...\...\.........\producer\ProducerSample.java
.........\start.sh
.........\stop.sh
.........\bin\com\kafkatest\consumer
.........\...\...\.........\producer
.........\src\com\kafkatest\consumer
.........\...\...\.........\producer
.........\bin\com\kafkatest
.........\src\com\kafkatest
.........\bin\com
.........\src\com
.........\.settings
.........\bin
.........\lib
.........\src
KafkaTest