Skip to content

Commit

Permalink
Update docs/connectors/sinks/mongodb-sink.md
Browse files Browse the repository at this point in the history
Co-authored-by: Remy Gwaramadze <gwaramadze@users.noreply.github.com>
  • Loading branch information
tim-quix and gwaramadze authored Feb 4, 2025
1 parent d237aa4 commit 9bb24e1
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion docs/connectors/sinks/mongodb-sink.md
Original file line number Diff line number Diff line change
Expand Up @@ -76,7 +76,7 @@ from quixstreams.sinks.community.mongodb import MongoDBSink
from quixstreams.sinks.base.item import SinkItem

def match_on_last_name(batch_item: SinkItem):
return {"_id": SinkItem.value["name"]["last"]}
return {"_id": batch_item.value["name"]["last"]}

sink = MongoDBSink(
..., # other required stuff
Expand Down

0 comments on commit 9bb24e1

Please sign in to comment.