Class KafkaSource

java.lang.Object
com.hazelcast.pc.sources.KafkaSource
All Implemented Interfaces:
Source

public class KafkaSource extends Object implements Source
  • Constructor Details

    • KafkaSource

      public KafkaSource()
  • Method Details

    • source

      public com.hazelcast.jet.pipeline.GeneralStage source(com.hazelcast.jet.pipeline.Pipeline pipeline, StageConfig stageConfig)
      Specified by:
      source in interface Source