fix

consumer/src/index.ts

@@ -55,7 +55,7 @@ async function processStreamEntry(data: Record<string, string>) {
 
         const duration = Date.now() - start;
 
-        console.log('Entry processed in', duration, 'ms');
+        // console.log('Entry processed in', duration, 'ms');
 
     } catch (ex: any) {
         console.error('ERROR PROCESSING STREAM EVENT', ex.message);

producer/ecosystem.config.example.cjs

@@ -1,10 +1,10 @@
 module.exports = {
     apps: [
         {
-            name: 'Producer',
+            name: 'producer',
             port: '3000',
             exec_mode: 'cluster',
-            instances: '2',
+            instances: '1',
             script: './dist/broker/src/index.js',
             env: {
                 PORT: "",