Queue<E> persistQueue
com.fasterxml.jackson.databind.ObjectMapper mapper
KinesisWriterConfiguration config
List<E> streamName
ExecutorService executor
com.amazonaws.services.kinesis.AmazonKinesisClient client
Copyright © 2012–2016 The Apache Software Foundation. All rights reserved.