Each worker has it own consumer group

devit-tel · Sep 8, 2020 · d0c5aa6 · d0c5aa6
1 parent 577abbe
commit d0c5aa6
Showing 1 changed file with 9 additions and 2 deletions.
diff --git a/src/syncWorker.ts b/src/syncWorker.ts
@@ -86,14 +86,21 @@ export class SyncWorker extends EventEmitter {
       ...workerConfig,
     };
 
+    var tn = '';
+    if (Array.isArray(tasksName)) {
+      tn = tasksName.join('-');
+    } else {
+      tn = tasksName;
+    }
+
     this.consumer = new KafkaConsumer(
       {
         'bootstrap.servers': workerConfig.kafkaServers,
-        'group.id': `melonade-${this.workerConfig.namespace}.client`,
+        'group.id': `melonade-${this.workerConfig.namespace}-client-${tn}`,
         'enable.auto.commit': false,
         ...kafkaConfig,
       },
-      { 'auto.offset.reset': 'earliest' },
+      { 'auto.offset.reset': 'latest' },
     );
 
     this.consumer.on('ready', () => {