Package com.hazelcast.pc.sinks

Class KafkaSink

java.lang.Object

com.hazelcast.pc.sinks.KafkaSink

All Implemented Interfaces:

Sink

public class KafkaSink
extends Object
implements Sink

Constructor Summary

Constructors

Constructor	Description
KafkaSink()

Method Summary

Modifier and Type	Method	Description
SinkStage	sink(Object stage, StageConfig stageConfig)

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaSink

public KafkaSink()

Method Details

sink

public SinkStage sink(Object stage,
 StageConfig stageConfig)

Specified by:

sink in interface Sink