Package com.hazelcast.pc.sources
Class KafkaSource
java.lang.Object
com.hazelcast.pc.sources.KafkaSource
- All Implemented Interfaces:
Source
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptioncom.hazelcast.jet.pipeline.GeneralStage
source
(com.hazelcast.jet.pipeline.Pipeline pipeline, StageConfig stageConfig)
-
Constructor Details
-
KafkaSource
public KafkaSource()
-
-
Method Details
-
source
public com.hazelcast.jet.pipeline.GeneralStage source(com.hazelcast.jet.pipeline.Pipeline pipeline, StageConfig stageConfig)
-