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