edu.iu.dsc.tws.examples.connectors

Class KafkaExample.KSource

java.lang.Object

edu.iu.dsc.tws.connectors.kafka.KafkaSource

edu.iu.dsc.tws.examples.connectors.KafkaExample.KSource

All Implemented Interfaces:

INode, ISource, CheckpointableTask, java.io.Serializable

Enclosing class:

KafkaExample

public static class KafkaExample.KSource
extends KafkaSource

See Also:

Serialized Form

Field Summary

Fields inherited from class edu.iu.dsc.tws.connectors.kafka.KafkaSource

cfg, context

Constructor Summary

Constructors

Constructor and Description
KSource()

Method Summary

Modifier and Type	Method and Description
java.util.Properties	getConsumerProperties()
java.time.Duration	getPollingTimeout()
java.util.Set<java.lang.String>	getTopics()
void	writeRecord(ConsumerRecord kafkaRecord)

Methods inherited from class edu.iu.dsc.tws.connectors.kafka.KafkaSource

execute, getConsumerGroup, getKafkaConsumer, initSnapshot, onCheckpointPropagated, prepare, restoreSnapshot, takeSnapshot

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface edu.iu.dsc.tws.checkpointing.task.CheckpointableTask

onSnapshotPersisted

Constructor Detail

KSource

public KSource()

Method Detail

getConsumerProperties

public java.util.Properties getConsumerProperties()

Specified by:

getConsumerProperties in class KafkaSource

getTopics

public java.util.Set<java.lang.String> getTopics()

Specified by:

getTopics in class KafkaSource

writeRecord

public void writeRecord(ConsumerRecord kafkaRecord)

Specified by:

writeRecord in class KafkaSource

getPollingTimeout

public java.time.Duration getPollingTimeout()

Specified by:

getPollingTimeout in class KafkaSource