dataMoverTopic not required anymore and defaults to empty string

Do not create a consumer if no topic provided Issue: BB-565
scality · Oct 15, 2024 · 9557a91 · 9557a91
1 parent f868703
commit 9557a91
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/extensions/replication/ReplicationConfigValidator.js b/extensions/replication/ReplicationConfigValidator.js
@@ -53,7 +53,7 @@ const joiSchema = joi.object({
         bootstrapList: bootstrapListJoi,
     },
     topic: joi.string().required(),
-    dataMoverTopic: joi.string().required(),
+    dataMoverTopic: joi.string().default(''),
     replicationStatusTopic: joi.string().required(),
     monitorReplicationFailures: joi.boolean().default(true),
     replicationFailedTopic: joi.string().required(),

diff --git a/extensions/replication/queueProcessor/QueueProcessor.js b/extensions/replication/queueProcessor/QueueProcessor.js
@@ -753,8 +753,9 @@ class QueueProcessor extends EventEmitter {
                 if (options && options.disableConsumer) {
                     return done();
                 }
-                if (this.isReplayTopic) {
+                if (this.isReplayTopic || !this.repConfig.dataMoverTopic) {
                     // Do not process dataMover topic in replay processors
+                    // or if dataMover topic is not configured
                     return done();
                 }
                 this._dataMoverConsumer = this._createConsumer(