Queue<E> persistQueue
com.fasterxml.jackson.databind.ObjectMapper mapper
KafkaConfiguration config
kafka.javaapi.consumer.ConsumerConnector consumerConnector
List<E> inStreams
ExecutorService executor
Copyright © 2012–2016 The Apache Software Foundation. All rights reserved.