C E G H I K O P R S T W

C

cleanUp() - Method in class org.apache.streams.kafka.KafkaPersistReader

cleanUp() - Method in class org.apache.streams.kafka.KafkaPersistWriter

E

equals(Object) - Method in class org.apache.streams.kafka.KafkaConfiguration

G

getAdditionalProperties() - Method in class org.apache.streams.kafka.KafkaConfiguration

getBrokerlist() - Method in class org.apache.streams.kafka.KafkaConfiguration

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

getGroupId() - Method in class org.apache.streams.kafka.KafkaConfiguration

A required field for partitioning distributed consumers

getId() - Method in class org.apache.streams.kafka.KafkaPersistReader

getId() - Method in class org.apache.streams.kafka.KafkaPersistWriter

getPersistQueue() - Method in class org.apache.streams.kafka.KafkaPersistWriter

getTopic() - Method in class org.apache.streams.kafka.KafkaConfiguration

A topic to read/write from

getZkconnect() - Method in class org.apache.streams.kafka.KafkaConfiguration

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

H

hashCode() - Method in class org.apache.streams.kafka.KafkaConfiguration

I

inStreams - Variable in class org.apache.streams.kafka.KafkaPersistReader

isRunning() - Method in class org.apache.streams.kafka.KafkaPersistReader

K

KafkaConfiguration - Class in org.apache.streams.kafka

KafkaConfiguration() - Constructor for class org.apache.streams.kafka.KafkaConfiguration

KafkaPersistReader - Class in org.apache.streams.kafka

KafkaPersistReader reads documents from kafka.

KafkaPersistReader() - Constructor for class org.apache.streams.kafka.KafkaPersistReader

KafkaPersistReader constructor - resolves KafkaConfiguration from JVM 'kafka'.

KafkaPersistReader(Queue<StreamsDatum>) - Constructor for class org.apache.streams.kafka.KafkaPersistReader

KafkaPersistReader constructor - uses supplied persistQueue.

KafkaPersistReaderTask - Class in org.apache.streams.kafka

KafkaPersistReaderTask reads documents from kafka on behalf of

KafkaPersistReaderTask(KafkaPersistReader, KafkaStream<String, String>) - Constructor for class org.apache.streams.kafka.KafkaPersistReaderTask

KafkaPersistWriter - Class in org.apache.streams.kafka

KafkaPersistWriter writes documents to kafka.

KafkaPersistWriter() - Constructor for class org.apache.streams.kafka.KafkaPersistWriter

KafkaPersistWriter constructor

KafkaPersistWriter(Queue<StreamsDatum>) - Constructor for class org.apache.streams.kafka.KafkaPersistWriter

KafkaPersistWriter constructor - uses supplied persistQueue.

KafkaPersistWriterTask - Class in org.apache.streams.kafka

KafkaPersistWriterTask writes documents to kafka on behalf of

KafkaPersistWriterTask(KafkaPersistWriter) - Constructor for class org.apache.streams.kafka.KafkaPersistWriterTask

O

org.apache.streams.kafka - package org.apache.streams.kafka

P

persistQueue - Variable in class org.apache.streams.kafka.KafkaPersistReader

persistQueue - Variable in class org.apache.streams.kafka.KafkaPersistWriter

prepare(Object) - Method in class org.apache.streams.kafka.KafkaPersistReader

prepare(Object) - Method in class org.apache.streams.kafka.KafkaPersistWriter

R

readAll() - Method in class org.apache.streams.kafka.KafkaPersistReader

readCurrent() - Method in class org.apache.streams.kafka.KafkaPersistReader

readNew(BigInteger) - Method in class org.apache.streams.kafka.KafkaPersistReader

readRange(DateTime, DateTime) - Method in class org.apache.streams.kafka.KafkaPersistReader

run() - Method in class org.apache.streams.kafka.KafkaPersistReaderTask

run() - Method in class org.apache.streams.kafka.KafkaPersistWriter

run() - Method in class org.apache.streams.kafka.KafkaPersistWriterTask

S

setAdditionalProperty(String, Object) - Method in class org.apache.streams.kafka.KafkaConfiguration

setBrokerlist(String) - Method in class org.apache.streams.kafka.KafkaConfiguration

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

setConfig(KafkaConfiguration) - Method in class org.apache.streams.kafka.KafkaPersistReader

setConfig(KafkaConfiguration) - Method in class org.apache.streams.kafka.KafkaPersistWriter

setGroupId(String) - Method in class org.apache.streams.kafka.KafkaConfiguration

A required field for partitioning distributed consumers

setPersistQueue(Queue<StreamsDatum>) - Method in class org.apache.streams.kafka.KafkaPersistWriter

setTopic(String) - Method in class org.apache.streams.kafka.KafkaConfiguration

A topic to read/write from

setZkconnect(String) - Method in class org.apache.streams.kafka.KafkaConfiguration

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

start() - Method in class org.apache.streams.kafka.KafkaPersistWriter

run persist writer thread

startStream() - Method in class org.apache.streams.kafka.KafkaPersistReader

stop() - Method in class org.apache.streams.kafka.KafkaPersistWriter

STREAMS_ID - Static variable in class org.apache.streams.kafka.KafkaPersistReader

STREAMS_ID - Static variable in class org.apache.streams.kafka.KafkaPersistWriter

T

toString() - Method in class org.apache.streams.kafka.KafkaConfiguration

W

withAdditionalProperty(String, Object) - Method in class org.apache.streams.kafka.KafkaConfiguration

withBrokerlist(String) - Method in class org.apache.streams.kafka.KafkaConfiguration

withGroupId(String) - Method in class org.apache.streams.kafka.KafkaConfiguration

withTopic(String) - Method in class org.apache.streams.kafka.KafkaConfiguration

withZkconnect(String) - Method in class org.apache.streams.kafka.KafkaConfiguration

write(StreamsDatum) - Method in class org.apache.streams.kafka.KafkaPersistWriter

C E G H I K O P R S T W