MongoDB Change Stream

NAME	RUNTIME	TYPE	VERSION	STATUS
mongodb_change_stream	wombat	source	latest	preview

Consume the MongoDB ChangeStream. This input is capable of reading change events from a MongoDB client, database, or collection. When a database as well as a collection is provided, only changes to that collection will be read. When only a database is provided, changes to all collections in that database will be read. When neither a database nor a collection is provided, changes to all databases and collections will be read.

Configuration

name	type	optional	secret	description
uri	string	no	no	MongoDB connection URI
database	string	yes	no	The database to watch.
collection	string	yes	no	The collection to watch.
auto_replay_nacks	bool	no	no	Whether messages that are rejected (nacked) at the output level should be automatically replayed indefinitely, eventually resulting in back pressure if the cause of the rejections is persistent. If set to `false` these messages will instead be deleted. Disabling auto replays can greatly improve memory efficiency of high throughput streams as the original shape of the data can be discarded immediately upon consumption and mutation. The value defaults to `true`.