static <T> PostgreSQLSource.Builder<T> |
PostgreSQLSource.builder() |
Deprecated.
|
PostgreSQLSource.Builder<T> |
PostgreSQLSource.Builder.database(String database) |
The name of the PostgreSQL database from which to stream the changes.
|
PostgreSQLSource.Builder<T> |
PostgreSQLSource.Builder.debeziumProperties(Properties properties) |
The Debezium Postgres connector properties.
|
PostgreSQLSource.Builder<T> |
PostgreSQLSource.Builder.decodingPluginName(String name) |
The name of the Postgres logical decoding plug-in installed on the server.
|
PostgreSQLSource.Builder<T> |
PostgreSQLSource.Builder.deserializer(DebeziumDeserializationSchema<T> deserializer) |
The deserializer used to convert from consumed SourceRecord.
|
PostgreSQLSource.Builder<T> |
PostgreSQLSource.Builder.hostname(String hostname) |
|
PostgreSQLSource.Builder<T> |
PostgreSQLSource.Builder.password(String password) |
Password to use when connecting to the PostgreSQL database server.
|
PostgreSQLSource.Builder<T> |
PostgreSQLSource.Builder.port(int port) |
Integer port number of the PostgreSQL database server.
|
PostgreSQLSource.Builder<T> |
PostgreSQLSource.Builder.schemaList(String... schemaList) |
An optional list of regular expressions that match schema names to be monitored; any
schema name not included in the whitelist will be excluded from monitoring.
|
PostgreSQLSource.Builder<T> |
PostgreSQLSource.Builder.slotName(String slotName) |
The name of the PostgreSQL logical decoding slot that was created for streaming changes
from a particular plug-in for a particular database/schema.
|
PostgreSQLSource.Builder<T> |
PostgreSQLSource.Builder.tableList(String... tableList) |
An optional list of regular expressions that match fully-qualified table identifiers for
tables to be monitored; any table not included in the whitelist will be excluded from
monitoring.
|
PostgreSQLSource.Builder<T> |
PostgreSQLSource.Builder.username(String username) |
Name of the PostgreSQL database to use when connecting to the PostgreSQL database server.
|