{"repo":"damianiandrea/mongodb-nats-connector","free":true,"listed":false,"github":"https://github.com/damianiandrea/mongodb-nats-connector","clone":"git clone https://github.com/damianiandrea/mongodb-nats-connector.git","description":"A connector that uses MongoDB's change streams to capture data changes and publishes those changes to NATS JetStream.","language":"Go","stars":61,"topics":["mongodb","nats","golang","change-data-capture","source-connector"],"license":"MIT","category":"data-pipelines","readme_excerpt":"MongoDB-NATS Connector A connector that uses MongoDB's change streams to capture data changes and publishes those changes to NATS JetStream. I wanted an easy way to do CDC (change data capture) with MongoDB and sink the data to NATS, but couldn't find any existing solution, so I decided to build my own. Quick Start The quickest way to start is to clone the repository and use the following command to run a MongoDB replica set, a NATS cluster with JetStream enabled, and the connector itself: The connector will pick up the example connector.yaml configuration file, and it will perform the following actions: Create a MongoDB database named test-connector , and two MongoDB collections named coll1 and coll2 , if they do not already exist. These are the collections to be watched. Create a MongoDB database named resume-tokens , and two MongoDB collections named coll1 and coll2 , if they do not already exist. These are the collections where the resume tokens will be stored. Create two streams on NATS JetStream, COLL1 and COLL2 , if they do not already exist. Start watching the coll1 and coll2 collections, publishing any change event to NATS COLL1 and COLL2 streams respectively. Depending on the operation type, a different stream subject will be used, for example inserting a document in coll1 will result in a message being published on COLL1.insert , for updates it will be COLL1.update , for replacements COLL1.replace , and for deletions COLL1.delete . Check that the connector is up an","default_branch":null,"files":null,"tree":[],"storefront":"/r/damianiandrea","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/damianiandrea/mongodb-nats-connector/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}