@Test
public void connectorIsPresent() {

    final Document event = new Document().append("ts", new BsonTimestamp(100, 2))
            .append("h", Long.valueOf(1987654321))
            .append("ns", "dbA.collectA");
    source.opLogEvent("rs", event);
    assertThat(source.struct().getString(SourceInfo.DEBEZIUM_CONNECTOR_KEY)).isEqualTo(Module.name());
}