This project has retired. For details please refer to its Attic page.
Index (streams-persist-kafka 0.5.2-SNAPSHOT API)
Skip navigation links
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 
Skip navigation links

Copyright © 2018 The Apache Software Foundation. All rights reserved.