String brokerlist
String zkconnect
String topic
String groupId
Map<K,V> additionalProperties
Queue<E> persistQueue
com.fasterxml.jackson.databind.ObjectMapper mapper
KafkaConfiguration config
kafka.consumer.ConsumerConfig consumerConfig
kafka.javaapi.consumer.ConsumerConnector consumerConnector
List<E> inStreams
ExecutorService executor
Queue<E> persistQueue
com.fasterxml.jackson.databind.ObjectMapper mapper
KafkaConfiguration config
kafka.javaapi.producer.Producer<K,V> producer
Copyright © 2012–2016 The Apache Software Foundation. All rights reserved.