Repository files navigation

Welcome to the MongoDB Change Streams Plugin for Benthos! This plugin allows you to seamlessly stream data changes from your MongoDB database using Benthos, a versatile stream processor.

• Real-time Data Streaming: Capture data changes in real-time as they happen in your MongoDB database.

• Flexible Configuration: Easily configure the plugin to specify the database connection details

Before you begin, make sure you have the following prerequisites:

• Benthos: Required to import into your Golang code

• MongoDB: Change streams are available for replica sets and sharded clusters:

To get started you have to run benthos with custom plugins. Since this plugin is not adopted by benthos itselfyou have to create a new benthos build with plugin registered

package mainimport ("github.com/benthosdev/benthos/v4/public/service"// import mongodb_stream plugin_"github.com/usedatabrew/mongodb_stream_benthos")funcmain() {// here we initialize benthosservice.Run()}

input:label:mongodb_stream_input# register new pluginmongodb_stream:uri:database uridatabase:name of the databasecollection:collection namestream_snapshot:set true if you want to stream existing data. If set to false only a new data will be streamed