Striim 3.9.8 documentation

PostgreSQL Reader properties

Striim provides templates for creating applications that read from PostgreSQL and write to various targets. See Creating a new application using a template for details.

Starting with Striim 3.9.0, PostgreSQL JDBC driver is included with the Striim server. When running a PostgreSQLReader source with the Forwarding Agent, the driver must be installed as described in Installing the PostgreSQL JDBC driver.

property

type

default value

notes

Bidirectional Marker Table

java. lang. String

When performing bidirectional replication, the fully qualified name of the marker table (see Bidirectional replication). This setting is case-sensitive.

Connection Retry Policy

java. lang. String

retryInterval=30, maxRetries=3

With the default setting, if a connection attempt is unsuccessful, the adapter will try again in 30 seconds (retryInterval. If the second attempt is unsuccessful, in 30 seconds it will try a third time (maxRetries). If that is unsuccessful, the adapter will fail and log an exception. Negative values are not supported.

Connection URL

java. lang. String

jdbc:postgresql:// followed by the server's IP address or network name, a colon, the port number, and a slash followed by the database name. If the database name is omitted, the Username value is used as the database name.

Excluded Tables

java. lang. String

Change data for any tables specified here will not be returned. For example, if Tables uses a wildcard, data from any tables specified here will be omitted. Multiple table names and wildcards may be used as for Tables.

Filter Transaction Boundaries

java. lang. Boolean

True

With the default value of True, begin and commit transactions are filtered out. Set to False to include begin and commit transactions.

Password

com. webaction. security. Password

the password specified for the username (see Encrypted passwords)

Replication Slot Name

java. lang. String

striim_slot

The name of the replication slot created as described in PostgreSQL setup. If you have multiple instances of PostgreSQLReader, each must have its own slot.

Start LSN

java. lang. String

By default, only new transactions are read. Optionally, specify a log sequence number to start reading from that point.

Tables

java. lang. String

The table(s) for which to return change data. Tables must have primary keys (required for logical replication).

Names are case-sensitive. Specify source table names as <schema>.<table>) (The database is specified in the connection URL.

You may specify multiple tables as a list separated by semicolons or using the following wildcards in the schema and/or table names only (not in the database name):

  • %: any series of characters

  • _: any single character

For example, %.% would include all tables in all schemas in the database specified in the connection URL.

All tables specified must have primary keys. Tables without primary keys are not included in output.

If any specified tables are missing PostgresReader will issue a warning. If none of the specified tables exists, start will fail with a "found no tables" error.

If you have multiple instances of PostgreSQLReader, each should read a separate set of tables.

Username

java. lang. String

the login name for the user created as described in PostgreSQL setup

In this section: