Types & classes — github.com/beyondj2ee/flumeng-kafka-plugin

CodeHub MCPcopy Create free account

hub / github.com/beyondj2ee/flumeng-kafka-plugin / types & classes

Types & classes10 in github.com/beyondj2ee/flumeng-kafka-plugin

⨍ Functions 24 ◇ Types & classes 10

ClassConsumerChecker

Kafka Message Checker. User: beyondj2ee Date: 13. 9. 6 Time: PM 5:23

flumeng-kafka-plugin/src/test/java/org/apache/flume/plugins/test/ConsumerChecker.java:21

ClassConsumerWorker

Real Consumer Thread.

flumeng-kafka-plugin/src/test/java/org/apache/flume/plugins/test/ConsumerChecker.java:118

ClassConsumerWorker

Real Consumer Thread.

flumeng-kafka-plugin/src/main/java/org/apache/flume/plugins/KafkaSource.java:193

ClassJunitConstans

define constans for junit. User: beyondj2ee Date: 13. 9. 9 Time: AM 10:34

flumeng-kafka-plugin/src/test/java/org/apache/flume/plugins/test/JunitConstans.java:25

ClassKafkaFlumeConstans

Flume Kafka Constans. User: beyondj2ee Date: 13. 9. 9 Time: AM 11:05

flumeng-kafka-plugin/src/main/java/org/apache/flume/plugins/KafkaFlumeConstans.java:25

flumeng-kafka-plugin/src/main/java/org/apache/flume/plugins/KafkaSink.java:46

ClassKafkaSinkTest

Kafka Test for Sink. User: beyondj2ee. Date: 13. 9. 5 Time: PM 1:44.

flumeng-kafka-plugin/src/test/java/org/apache/flume/plugins/test/KafkaSinkTest.java:39

ClassKafkaSource

Kafka Flume Source (Kafka 0.8 Beta, Flume 1.4). User: beyondj2ee Date: 13. 9. 9 Time: AM 9:56

flumeng-kafka-plugin/src/main/java/org/apache/flume/plugins/KafkaSource.java:51

ClassKafkaSourceTest

Kafka Test for Source. User: Administrator Date: 13. 9. 9 Time: AM 10:47

flumeng-kafka-plugin/src/test/java/org/apache/flume/plugins/test/KafkaSourceTest.java:47

ClassSinglePartition

The type Single partition.

flumeng-kafka-plugin/src/main/java/org/apache/flume/plugins/SinglePartition.java:17