Skip to content

Commit

Permalink
fix a couple things in mongodb sink doc (#746)
Browse files Browse the repository at this point in the history
  • Loading branch information
tim-quix authored Feb 11, 2025
1 parent b5c5b40 commit af5fdcb
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions docs/connectors/sinks/mongodb-sink.md
Original file line number Diff line number Diff line change
Expand Up @@ -206,6 +206,7 @@ mongodb_sink = MongoDBSink(

- `url`: MongoDB url; most commonly `mongodb://username:password@host:port`
- `db`: MongoDB database name
- `collection`: MongoDB collection name
- `document_matcher`: How documents are selected to update.
A callable that accepts a `BatchItem` and returns a MongoDB "Filter Query".
If no match, will insert if `upsert=True`, where `_id` will be either the
Expand All @@ -220,9 +221,9 @@ mongodb_sink = MongoDBSink(
- "UpdateMany": Updates ALL matching documents (usually NOT based on `_id`).
- "ReplaceOne": Replaces the first matching document (usually based on `_id`).
**Default**: "UpdateOne".
- `include_message_metadata`: include key, timestamp, and headers as `__{field}`
- `add_message_metadata`: include key, timestamp, and headers as `__{field}`
**Default**: False
- `include_topic_metadata`: include topic, partition, and offset as `__{field}`
- `add_topic_metadata`: include topic, partition, and offset as `__{field}`
**Default**: False
- `value_selector`: An optional callable that allows final editing of the
outgoing document (right before submitting it).
Expand Down

0 comments on commit af5fdcb

Please sign in to comment.