diff --git a/test/integration/backward_compatible/parallel/serialization/compact/CompactPublicAPIsTest.js b/test/integration/backward_compatible/parallel/serialization/compact/CompactPublicAPIsTest.js
index 2b82767fb..6d42e6626 100644
--- a/test/integration/backward_compatible/parallel/serialization/compact/CompactPublicAPIsTest.js
+++ b/test/integration/backward_compatible/parallel/serialization/compact/CompactPublicAPIsTest.js
@@ -1093,6 +1093,10 @@ describe('CompactPublicAPIsTest', function () {
     });
 
     describe('Topic', function () {
+        before(function () {
+            TestUtil.markClientVersionAtLeast(this, '6.0');
+        });
+
         it('publish', async function () {
             const fn = topic.publish.bind(topic, OUTER_INSTANCE);
             await fn();
diff --git a/test/integration/backward_compatible/parallel/topic/ReliableTopicTest.js b/test/integration/backward_compatible/parallel/topic/ReliableTopicTest.js
index 5ada33d7d..428feda2f 100644
--- a/test/integration/backward_compatible/parallel/topic/ReliableTopicTest.js
+++ b/test/integration/backward_compatible/parallel/topic/ReliableTopicTest.js
@@ -124,13 +124,22 @@ describe('ReliableTopicTest', function () {
             topicOne.publish({ 'value0': 'foo0' });
             topicOne.publish({ 'value1': 'foo1' });
             setTimeout(() => {
-                topicTwo.removeMessageListener(id).then(() => {
-                    topicOne.publish({ 'value2': 'foo2' });
-                    topicOne.publish({ 'value3': 'foo3' });
-                    topicOne.publish({ 'value4': 'foo4' });
-                    topicOne.publish({ 'value5': 'foo5' });
+                if (TestUtil.isClientVersionAtLeast('6.0')) {
+                    topicTwo.removeMessageListener(id).then(() => {
+                        topicOne.publish({'value2': 'foo2'});
+                        topicOne.publish({'value3': 'foo3'});
+                        topicOne.publish({'value4': 'foo4'});
+                        topicOne.publish({'value5': 'foo5'});
+                        setTimeout(done, 500);
+                    });
+                } else {
+                    topicTwo.removeMessageListener(id);
+                    topicOne.publish({'value2': 'foo2'});
+                    topicOne.publish({'value3': 'foo3'});
+                    topicOne.publish({'value4': 'foo4'});
+                    topicOne.publish({'value5': 'foo5'});
                     setTimeout(done, 500);
-                });
+                }
             }, 500);
         }).catch(done);
     });