diff --git a/.ci/tests/integration/cases/mongodb-source/manifests.yaml b/.ci/tests/integration/cases/mongodb-source/manifests.yaml
index 954b936c..653808f3 100644
--- a/.ci/tests/integration/cases/mongodb-source/manifests.yaml
+++ b/.ci/tests/integration/cases/mongodb-source/manifests.yaml
@@ -38,9 +38,9 @@ spec:
       hostnameVerification: true
       certSecretName: sn-platform-tls-broker
       certSecretKey: ""
-  image: streamnative/pulsar-io-debezium-mongodb:3.2.2.1
+  image: streamnative/pulsar-io-debezium-mongodb:2.9.2.23
   java:
-    jar: connectors/pulsar-io-debezium-mongodb-3.2.2.1.nar
+    jar: connectors/pulsar-io-debezium-mongodb-2.9.2.23.nar
     jarLocation: "" # use pulsar provided connectors
     # use package name:
     # jarLocation: function://public/default/nul-test-java-source@v1
diff --git a/.ci/tests/integration/cases/mongodb-source/verify.sh b/.ci/tests/integration/cases/mongodb-source/verify.sh
index 2d9c0b38..5f41493c 100644
--- a/.ci/tests/integration/cases/mongodb-source/verify.sh
+++ b/.ci/tests/integration/cases/mongodb-source/verify.sh
@@ -78,7 +78,7 @@ if [ $? -ne 0 ]; then
 fi
 
 if [ $USE_TLS == "false" ]; then
-  verify_log_topic=$(ci::verify_log_topic persistent://public/default/mongo-source-logs "it may be a NAR file" 10 2>&1)
+  verify_log_topic=$(ci::verify_log_topic persistent://public/default/mongo-source-logs "org.apache.pulsar.functions.runtime.JavaInstanceStarter" 10 2>&1)
   if [ $? -ne 0 ]; then
     echo "$verify_log_topic"
     kubectl delete -f "${manifests_file}" > /dev/null 2>&1 || true