public class VerifiableSourceTask
extends org.apache.kafka.connect.source.SourceTask
If logging is left enabled, log output on stdout can be easily ignored by checking whether a given line is valid JSON.
Modifier and Type | Field and Description |
---|---|
static String |
COMPLETE_RECORD_DATA_CONFIG |
static String |
ID_CONFIG |
static String |
NAME_CONFIG |
static String |
THROUGHPUT_CONFIG |
static String |
TOPIC_CONFIG |
Constructor and Description |
---|
VerifiableSourceTask() |
Modifier and Type | Method and Description |
---|---|
void |
commitRecord(org.apache.kafka.connect.source.SourceRecord record,
org.apache.kafka.clients.producer.RecordMetadata metadata) |
List<org.apache.kafka.connect.source.SourceRecord> |
poll() |
void |
start(Map<String,String> props) |
void |
stop() |
String |
version() |
public static final String NAME_CONFIG
public static final String ID_CONFIG
public static final String TOPIC_CONFIG
public static final String THROUGHPUT_CONFIG
public static final String COMPLETE_RECORD_DATA_CONFIG
public String version()
public void start(Map<String,String> props)
start
in interface org.apache.kafka.connect.connector.Task
start
in class org.apache.kafka.connect.source.SourceTask
public List<org.apache.kafka.connect.source.SourceRecord> poll()
poll
in class org.apache.kafka.connect.source.SourceTask
public void commitRecord(org.apache.kafka.connect.source.SourceRecord record, org.apache.kafka.clients.producer.RecordMetadata metadata)
commitRecord
in class org.apache.kafka.connect.source.SourceTask
public void stop()
stop
in interface org.apache.kafka.connect.connector.Task
stop
in class org.apache.kafka.connect.source.SourceTask