Serialized Form

Package org.apache.streams.kafka

Class org.apache.streams.kafka.KafkaConfiguration extends Object implements Serializable

Serialized Fields

brokerlist

String brokerlist

A comma-delimited list of broker nodes, used by producer

zkconnect

String zkconnect

A comma-delimited list of zookeeper host:ports, used by consumer

topic

String topic

A topic to read/write from

groupId

String groupId

A required field for partitioning distributed consumers

additionalProperties

Map<K,V> additionalProperties

Class org.apache.streams.kafka.KafkaPersistReader extends Object implements Serializable

Serialized Fields

persistQueue

Queue<E> persistQueue

mapper

com.fasterxml.jackson.databind.ObjectMapper mapper

config

KafkaConfiguration config

consumerConnector

kafka.javaapi.consumer.ConsumerConnector consumerConnector

inStreams

List<E> inStreams

executor

ExecutorService executor

Class org.apache.streams.kafka.KafkaPersistWriter extends Object implements Serializable

Serialized Fields

persistQueue

Queue<E> persistQueue

mapper

com.fasterxml.jackson.databind.ObjectMapper mapper

config

KafkaConfiguration config

producer

kafka.javaapi.producer.Producer<K,V> producer