Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-32344

MongoDB connector support unbounded streaming read via ChangeStream feature

    XMLWordPrintableJSON

Details

    Description

      Change streams allow applications to access real-time data changes without the complexity and risk of tailing the oplog. Applications can use change streams to subscribe to all data changes on a single collection, a database, or an entire deployment, and immediately react to them. Because change streams use the aggregation framework, applications can also filter for specific changes or transform the notifications at will.

      We can use MongoDB change streams feature to support unbounded streaming read for mongodb connector.

      Change Streams

      Attachments

        Issue Links

          Activity

            People

              jiabao.sun jiabao.sun
              jiabao.sun jiabao.sun
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated: