public class MockSinkTask
extends org.apache.kafka.connect.sink.SinkTask
Constructor and Description |
---|
MockSinkTask() |
Modifier and Type | Method and Description |
---|---|
void |
put(Collection<org.apache.kafka.connect.sink.SinkRecord> records) |
void |
start(Map<String,String> config) |
void |
stop() |
String |
version() |
public String version()
public void start(Map<String,String> config)
start
in interface org.apache.kafka.connect.connector.Task
start
in class org.apache.kafka.connect.sink.SinkTask
public void put(Collection<org.apache.kafka.connect.sink.SinkRecord> records)
put
in class org.apache.kafka.connect.sink.SinkTask
public void stop()
stop
in interface org.apache.kafka.connect.connector.Task
stop
in class org.apache.kafka.connect.sink.SinkTask