org.apache.flume.shared.kafka.test (Apache Flume 1.9.0-cdh6.3.2 API)