Path	Lines of Code
flume-kafka-channel/src/test/java/org/apache/flume/channel/kafka/TestBasicFunctionality.java	158
flume-kafka-channel/src/test/java/org/apache/flume/channel/kafka/TestKafkaChannelBase.java	230
flume-kafka-channel/src/test/java/org/apache/flume/channel/kafka/TestOffsetsAndMigration.java	44
flume-kafka-channel/src/test/java/org/apache/flume/channel/kafka/TestParseAsFlumeEvent.java	96
flume-kafka-channel/src/test/java/org/apache/flume/channel/kafka/TestPartitions.java	107
flume-kafka-channel/src/test/java/org/apache/flume/channel/kafka/TestRollback.java	66
flume-kafka-channel/src/test/resources/log4j2.xml	54
flume-kafka-sink/src/test/java/org/apache/flume/sink/kafka/TestConstants.java	12
flume-kafka-sink/src/test/java/org/apache/flume/sink/kafka/TestKafkaSink.java	648
flume-kafka-sink/src/test/java/org/apache/flume/sink/kafka/util/KafkaLocal.java	21
flume-kafka-sink/src/test/java/org/apache/flume/sink/kafka/util/TestUtil.java	227
flume-kafka-sink/src/test/java/org/apache/flume/sink/kafka/util/ZooKeeperLocal.java	33
flume-kafka-sink/src/test/resources/log4j2.xml	54
flume-kafka-source/src/test/java/org/apache/flume/source/kafka/KafkaSourceEmbeddedKafka.java	164
flume-kafka-source/src/test/java/org/apache/flume/source/kafka/KafkaSourceEmbeddedZookeeper.java	44
flume-kafka-source/src/test/java/org/apache/flume/source/kafka/TestKafkaSource.java	715
flume-kafka-source/src/test/resources/log4j2.xml	14
flume-shared/flume-shared-kafka-test/src/main/java/org/apache/flume/shared/kafka/test/KafkaPartitionTestUtil.java	116
flume-shared/flume-shared-kafka-test/src/main/java/org/apache/flume/shared/kafka/test/PartitionOption.java	6
flume-shared/flume-shared-kafka-test/src/main/java/org/apache/flume/shared/kafka/test/PartitionTestScenario.java	7
flume-shared/flume-shared-kafka/src/test/java/org/apache/flume/shared/kafka/KafkaSSLUtilTest.java	127