diff --git a/consumer/src/index.ts b/consumer/src/index.ts index f3895e4..3c466cb 100644 --- a/consumer/src/index.ts +++ b/consumer/src/index.ts @@ -55,7 +55,7 @@ async function processStreamEntry(data: Record) { 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); diff --git a/producer/ecosystem.config.example.cjs b/producer/ecosystem.config.example.cjs index cdd646d..bc47f0f 100644 --- a/producer/ecosystem.config.example.cjs +++ b/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: "",