Subscriber getSubscriber()

in flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSource.java [470:472]


  <T> Subscriber<T> getSubscriber() {
    return subscriber;
  }