static <T> VitessSource.Builder<T> |
VitessSource.builder() |
|
VitessSource.Builder<T> |
VitessSource.Builder.columnExcludeList(String... columnExcludeList) |
An optional, comma-separated list of regular expressions that match the fully-qualified
names of columns that should be excluded from change event record values.
|
VitessSource.Builder<T> |
VitessSource.Builder.columnIncludeList(String... columnIncludeList) |
An optional, comma-separated list of regular expressions that match the fully-qualified
names of columns that should be included in change event record values.
|
VitessSource.Builder<T> |
VitessSource.Builder.debeziumProperties(Properties properties) |
The Debezium Vitess connector properties.
|
VitessSource.Builder<T> |
VitessSource.Builder.decodingPluginName(String name) |
The name of the Vitess logical decoding plug-in installed on the server.
|
VitessSource.Builder<T> |
VitessSource.Builder.deserializer(DebeziumDeserializationSchema<T> deserializer) |
The deserializer used to convert from consumed SourceRecord.
|
VitessSource.Builder<T> |
VitessSource.Builder.gtid(String gtid) |
An optional GTID position for a shard to stream from.
|
VitessSource.Builder<T> |
VitessSource.Builder.hostname(String hostname) |
Hostname of the VTGate’s VStream server.
|
VitessSource.Builder<T> |
VitessSource.Builder.keyspace(String keyspace) |
The name of the keyspace (a.k.a database).
|
VitessSource.Builder<T> |
VitessSource.Builder.messageKeyColumns(String[] messageKeyColumns) |
A semicolon separated list of tables with regular expressions that match table column
names.
|
VitessSource.Builder<T> |
VitessSource.Builder.name(String name) |
Unique name for the connector.
|
VitessSource.Builder<T> |
VitessSource.Builder.password(String password) |
The password of the Vitess database server (VTGate gRPC).
|
VitessSource.Builder<T> |
VitessSource.Builder.port(int port) |
Integer port number of the VTGate’s VStream server.
|
VitessSource.Builder<T> |
VitessSource.Builder.schemaNameAdjustmentMode(SchemaAdjustmentMode schemaNameAdjustmentMode) |
Specifies how schema names should be adjusted for compatibility with the message
converter used by the connector.
|
VitessSource.Builder<T> |
VitessSource.Builder.shard(String shard) |
An optional name of the shard from which to stream the changes.
|
VitessSource.Builder<T> |
VitessSource.Builder.stopOnReshard(Boolean stopOnReshard) |
Controls Vitess flag stop_on_reshard.
|
VitessSource.Builder<T> |
VitessSource.Builder.tableExcludeList(String... tableExcludeList) |
An optional, comma-separated list of regular expressions that match fully-qualified table
identifiers for tables whose changes you do not want to capture.
|
VitessSource.Builder<T> |
VitessSource.Builder.tableIncludeList(String... tableIncludeList) |
An optional, comma-separated list of regular expressions that match fully-qualified table
identifiers for tables whose changes you want to capture.
|
VitessSource.Builder<T> |
VitessSource.Builder.tabletType(TabletType tabletType) |
The type of Tablet (hence MySQL) from which to stream the changes: MASTER represents
streaming from the master MySQL instance REPLICA represents streaming from the replica
slave MySQL instance RDONLY represents streaming from the read-only slave MySQL instance.
|
VitessSource.Builder<T> |
VitessSource.Builder.tombstonesOnDelete(Boolean tombstonesOnDelete) |
* Controls whether a delete event is followed by a tombstone event.
|
VitessSource.Builder<T> |
VitessSource.Builder.username(String username) |
The username of the Vitess database server (VTGate gRPC).
|