Hazelcast Jet Kinesis KinesisSources Sınıfı

Giriş

Şu satırı dahil ederiz

import com.hazelcast.jet.kinesis.KinesisSources;

kinesis metodu

Örnek

Şöyle yaparız

Pipeline p = Pipeline.create();
p.readFrom(KinesisSources.kinesis(STREAM).build())
  .withNativeTimestamps(0)
  .writeTo(Sinks.logger());