org.apache.flink.statefun.flink.io.kafka

Class KafkaSinkProvider

java.lang.Object

org.apache.flink.statefun.flink.io.kafka.KafkaSinkProvider

All Implemented Interfaces:

SinkProvider

public class KafkaSinkProvider
extends java.lang.Object
implements SinkProvider

Constructor Summary

Constructors

Constructor and Description
KafkaSinkProvider()

Method Summary

Modifier and Type	Method and Description
<T> org.apache.flink.streaming.api.functions.sink.SinkFunction<T>	forSpec(EgressSpec<T> egressSpec)

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaSinkProvider

public KafkaSinkProvider()

Method Detail

forSpec

public <T> org.apache.flink.streaming.api.functions.sink.SinkFunction<T> forSpec(EgressSpec<T> egressSpec)

Specified by:

forSpec in interface SinkProvider