Striim 3.9.4 / 3.9.5 documentation

MongoDBReader properties

The MongoDB driver is bundled with Striim, so no installation is necessary.

The adapter properties are:

property

type

default value

notes

authDB

java.lang.String

admin

Specify the authentication database for the specified username. If not specified, uses the admin database.  When the specified authType uses an external authentication server, this setting is ignored.

authType

enum

Default

Specify the authentication mechanism used by your MongoDB instance. The default setting uses MongoDB's default authentication mechanism, SCRAM. Other supported values are MONGODBCR and SCRAMSHA1. Set to NoAuth if authentication is not enabled. 

GSSAPI (Kerberos), MONGODBX509, and PLAIN (LDAP) are valid values for this property, but those authentication mechanisms have not been tested so are not supported.

Collections

java.lang.String

The fully-qualified name(s) of the MongoDB collection(s) to read from, for example, mydb.mycollection. Separate multiple collections by commas.

You may use the $ wildcard, for example, mydb.$ or mydb.a$. Note that data will be read only from collections that exist when the Striim application starts, additional collections added later will be ignored until the application is restarted.

Connection Retry Policy

java.lang.String

retryInterval=30, maxRetries=3

The connection retry policy includes retryInterval and maxRetries. 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

Specify one or more instances in the replica set, for example, 192.168.1.10:27107,192.168.1.11:27107. If you specify more than one instance, one should be the primary.

You may specify a mongos instance when the mode is InitialLoad but not when it is Incremental.

Exclude Collections

java.lang.String

Any collections to be excluded from the set specified in the Collections property. Specify as for the Collections property.

Mode

java.lang.String

InitialLoad

With the default setting, will load all existing data using db.collection.find()and stop. In this mode, MongoDBReader is not a CDC reader.

Set to Incremental to read CDC data continuously from the oplog.

Password

com. webaction.security. Password

The password for the specified Username.

Read Preference

enum

primaryPreferred

See Read Preference Modes. Supported values are primary, primaryPreferred, secondary, secondaryPreferred, and nearest.

SSL Enabled

java.lang.Boolean

False

If your MongoDB instance is using SSL (see Configure mongod and mongos for TLS/SSL), set to True.

Start Timestamp

java.lang.String

Leave blank to read only new data. Specify a UTC DateTime value (for example, 2018-07-18T04:56:10) to read all data from that time forward or to wait to start reading until a time in the future. If the MongoDB and Striim servers are in different time zones, adjust the value to match the Striim time zone. If the oplog no longer contains data back to the specified time, reading will start from the beginning of the oplog. 

If milliseconds are specified (for example, 2017-07-18T04:56:10.999), they will be interpreted as the incrementing ordinal for the MongoDB timestamp (see Timestamps).

Username

java.lang.String

A MongoDB user with access as described in MongoDB setup.