Package org.apache.flink.cdc.connectors.mongodb.internal

Class MongoDBConnectorSourceTask

java.lang.Object

org.apache.kafka.connect.source.SourceTask

org.apache.flink.cdc.connectors.mongodb.internal.MongoDBConnectorSourceTask

All Implemented Interfaces:

org.apache.kafka.connect.connector.Task

public class MongoDBConnectorSourceTask
extends org.apache.kafka.connect.source.SourceTask

Source Task that proxies mongodb kafka connector's MongoSourceTask to adapt to DebeziumChangeFetcher.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.kafka.connect.source.SourceTask

org.apache.kafka.connect.source.SourceTask.TransactionBoundary

Field Summary

Fields

Modifier and Type	Field	Description
static String	COLLECTION_INCLUDE_LIST
static String	DATABASE_INCLUDE_LIST
static String	STARTUP_MODE_INITIAL_SNAPSHOTTING_MAX_THREADS_CONFIG
static String	STARTUP_MODE_INITIAL_SNAPSHOTTING_PIPELINE_CONFIG
static String	STARTUP_MODE_INITIAL_SNAPSHOTTING_QUEUE_SIZE_CONFIG
static String	STARTUP_MODE_TIMESTAMP_START_AT_OPERATION_TIME_CONFIG

Fields inherited from class org.apache.kafka.connect.source.SourceTask

context, TRANSACTION_BOUNDARY_CONFIG

Constructor Summary

Constructors

Constructor	Description
MongoDBConnectorSourceTask()

Method Summary

Modifier and Type	Method	Description
void	commit()
void	commitRecord(org.apache.kafka.connect.source.SourceRecord record)
void	commitRecord(org.apache.kafka.connect.source.SourceRecord record, org.apache.kafka.clients.producer.RecordMetadata metadata)
void	initialize(org.apache.kafka.connect.source.SourceTaskContext context)
List<org.apache.kafka.connect.source.SourceRecord>	poll()
void	start(Map<String,String> props)
void	stop()
String	version()

Methods inherited from class java.lang.Object

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

Field Detail

DATABASE_INCLUDE_LIST

public static final String DATABASE_INCLUDE_LIST

See Also:

Constant Field Values

COLLECTION_INCLUDE_LIST

public static final String COLLECTION_INCLUDE_LIST

See Also:

Constant Field Values

STARTUP_MODE_INITIAL_SNAPSHOTTING_MAX_THREADS_CONFIG

public static final String STARTUP_MODE_INITIAL_SNAPSHOTTING_MAX_THREADS_CONFIG

See Also:

Constant Field Values

STARTUP_MODE_INITIAL_SNAPSHOTTING_QUEUE_SIZE_CONFIG

public static final String STARTUP_MODE_INITIAL_SNAPSHOTTING_QUEUE_SIZE_CONFIG

See Also:

Constant Field Values

STARTUP_MODE_INITIAL_SNAPSHOTTING_PIPELINE_CONFIG

public static final String STARTUP_MODE_INITIAL_SNAPSHOTTING_PIPELINE_CONFIG

See Also:

Constant Field Values

STARTUP_MODE_TIMESTAMP_START_AT_OPERATION_TIME_CONFIG

public static final String STARTUP_MODE_TIMESTAMP_START_AT_OPERATION_TIME_CONFIG

See Also:

Constant Field Values

Constructor Detail

MongoDBConnectorSourceTask

public MongoDBConnectorSourceTask()
                           throws NoSuchFieldException

Throws:

NoSuchFieldException

Method Detail

version

public String version()

initialize

public void initialize(org.apache.kafka.connect.source.SourceTaskContext context)

Overrides:

initialize in class org.apache.kafka.connect.source.SourceTask

start

public void start(Map<String,String> props)

Specified by:

start in interface org.apache.kafka.connect.connector.Task

Specified by:

start in class org.apache.kafka.connect.source.SourceTask

commit

public void commit()
            throws InterruptedException

Overrides:

commit in class org.apache.kafka.connect.source.SourceTask

Throws:

InterruptedException

commitRecord

public void commitRecord(org.apache.kafka.connect.source.SourceRecord record)
                  throws InterruptedException

Overrides:

commitRecord in class org.apache.kafka.connect.source.SourceTask

Throws:

InterruptedException

commitRecord

public void commitRecord(org.apache.kafka.connect.source.SourceRecord record,
                         org.apache.kafka.clients.producer.RecordMetadata metadata)
                  throws InterruptedException

Overrides:

commitRecord in class org.apache.kafka.connect.source.SourceTask

Throws:

InterruptedException

poll

public List<org.apache.kafka.connect.source.SourceRecord> poll()
                                                        throws InterruptedException

Specified by:

poll in class org.apache.kafka.connect.source.SourceTask

Throws:

InterruptedException

stop

public void stop()

Specified by:

stop in interface org.apache.kafka.connect.connector.Task

Specified by:

stop in class org.apache.kafka.connect.source.SourceTask