Package com.hazelcast.jet.cdc.mysql
Class MySqlCdcSources
java.lang.Object
com.hazelcast.jet.cdc.mysql.MySqlCdcSources
@EvolvingApi public final class MySqlCdcSources extends Object
Contains factory methods for creating change data capture sources
based on MySQL databases.
- Since:
- 4.2
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
MySqlCdcSources.Builder
Builder for configuring a CDC source that streams change data from a MySQL database to Hazelcast Jet. -
Method Summary
Modifier and Type Method Description static MySqlCdcSources.Builder
mysql(String name)
Creates a CDC source that streams change data from a MySQL database to Hazelcast Jet.
-
Method Details
-
mysql
Creates a CDC source that streams change data from a MySQL database to Hazelcast Jet.KNOWN ISSUE: If Jet can't reach the database when it attempts to start the source or if it looses the connection to the database from an already running source, it throws an exception and terminate the execution of the job. This behaviour is not ideal, would be much better to try to reconnect, at least for a certain amount of time. Future versions will address the problem.
- Parameters:
name
- name of this source, needs to be unique, will be passed to the underlying Kafka Connect source- Returns:
- builder that can be used to set source properties and also to construct the source once configuration is done
-