public class KafkaStreamer<T,K,V> extends StreamAdapter<T,K,V>
IgniteDataStreamer instance.
Uses Kafka's High Level Consumer API to read messages from Kafka.
| Constructor and Description |
|---|
KafkaStreamer() |
| Modifier and Type | Method and Description |
|---|---|
void |
setConsumerConfig(kafka.consumer.ConsumerConfig consumerCfg)
Sets the consumer config.
|
void |
setKeyDecoder(kafka.serializer.Decoder<K> keyDecoder)
Sets the key decoder.
|
void |
setRetryTimeout(long retryTimeout)
Sets the retry timeout.
|
void |
setThreads(int threads)
Sets the threads.
|
void |
setTopic(String topic)
Sets the topic name.
|
void |
setValueDecoder(kafka.serializer.Decoder<V> valDecoder)
Sets the value decoder.
|
void |
start()
Starts streamer.
|
void |
stop()
Stops streamer.
|
addMessage, getIgnite, getMultipleTupleExtractor, getSingleTupleExtractor, getStreamer, getTupleExtractor, setIgnite, setMultipleTupleExtractor, setSingleTupleExtractor, setStreamer, setTupleExtractorpublic void setTopic(String topic)
topic - Topic name.public void setThreads(int threads)
threads - Number of threads.public void setConsumerConfig(kafka.consumer.ConsumerConfig consumerCfg)
consumerCfg - Consumer configuration.public void setKeyDecoder(kafka.serializer.Decoder<K> keyDecoder)
keyDecoder - Key decoder.public void setValueDecoder(kafka.serializer.Decoder<V> valDecoder)
valDecoder - Value decoder.public void setRetryTimeout(long retryTimeout)
retryTimeout - Retry timeout.public void start()
IgniteException - If failed.public void stop()
Follow @ApacheIgnite
Ignite Fabric : ver. 1.5.11 Release Date : April 8 2016