KafkaPersistReaderTask(KafkaPersistReader reader, kafka.consumer.KafkaStream<String,String> stream)
Copyright © 2018 The Apache Software Foundation. All rights reserved.