You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by "david-streamlio (via GitHub)" <gi...@apache.org> on 2026/07/17 21:42:29 UTC

[I] [improve][test] Add integration tests for the MongoDB source connector [pulsar-connectors]

david-streamlio opened a new issue, #121:
URL: https://github.com/apache/pulsar-connectors/issues/121

   ## Current state
   
   The `mongo` module has integration coverage for the **sink** only: `MongoSinkContainerTest` runs `MongoSink` end-to-end against a real `MongoDBContainer` (Testcontainers, mongo:6.0).
   
   The **source** side has no integration coverage. `MongoSourceTest` is a pure Mockito unit test — it never starts a MongoDB instance, so the change-stream / `MongoSource` read path is exercised only against mocks. (`MongoSourceConfigTest` is config-only.)
   
   ## Proposal
   
   Add a Testcontainers-based integration test for `MongoSource` that:
   
   - starts a real MongoDB container (a replica set, since change streams require one),
   - runs `MongoSource` end-to-end,
   - writes documents to the watched collection and asserts the source emits the corresponding records.
   
   This mirrors the existing `MongoSinkContainerTest` harness on the source side, closing the sink/source coverage asymmetry.
   
   _Part of an integration-test coverage sweep of all connector modules._


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


Re: [I] [improve][test] Add integration tests for the MongoDB source connector [pulsar-connectors]

Posted by "david-streamlio (via GitHub)" <gi...@apache.org>.
david-streamlio closed issue #121: [improve][test] Add integration tests for the MongoDB source connector
URL: https://github.com/apache/pulsar-connectors/issues/121


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org