Package com.hazelcast.pc.sources

Class KafkaSource

java.lang.Object

com.hazelcast.pc.sources.KafkaSource

All Implemented Interfaces:

Source

public class KafkaSource
extends Object
implements Source

Constructor Summary

Constructors

Constructor	Description
KafkaSource()

Method Summary

Modifier and Type	Method	Description
GeneralStage	source(Pipeline pipeline, StageConfig stageConfig)

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaSource

public KafkaSource()

Method Details

source

public GeneralStage source(Pipeline pipeline,
 StageConfig stageConfig)

Specified by:

source in interface Source