config kafka authentication

crypitor · May 3, 2024 · 93baf59 · 93baf59
1 parent fac1d74
commit 93baf59
Show file tree

Hide file tree

Showing 4 changed files with 36 additions and 0 deletions.
diff --git a/app/apps/monitor-service/src/ethereum/ethereum.module.ts b/app/apps/monitor-service/src/ethereum/ethereum.module.ts
@@ -21,6 +21,15 @@ import { EthereumService } from './ethereum.service';
             client: {
               clientId: 'webhook',
               brokers: process.env.KAFKA_BROKERS.split(','),
+              ssl: process.env.KAFKA_SSL === 'true',
+              sasl:
+                process.env.KAFKA_AUTH_ENABLE === 'true'
+                  ? {
+                      mechanism: 'plain',
+                      username: process.env.KAFKA_USERNAME || '',
+                      password: process.env.KAFKA_PASSWORD || '',
+                    }
+                  : null,
             },
             consumer: {
               groupId: 'webhook-consumer',

diff --git a/app/apps/monitor-service/src/polygon/polygon.module.ts b/app/apps/monitor-service/src/polygon/polygon.module.ts
@@ -21,6 +21,15 @@ import { PolygonService } from './polygon.service';
             client: {
               clientId: 'webhook',
               brokers: process.env.KAFKA_BROKERS.split(','),
+              ssl: process.env.KAFKA_SSL === 'true',
+              sasl:
+                process.env.KAFKA_AUTH_ENABLE === 'true'
+                  ? {
+                      mechanism: 'plain',
+                      username: process.env.KAFKA_USERNAME || '',
+                      password: process.env.KAFKA_PASSWORD || '',
+                    }
+                  : null,
             },
             consumer: {
               groupId: 'webhook-consumer',

diff --git a/app/apps/onebox/src/main.module.ts b/app/apps/onebox/src/main.module.ts
@@ -30,6 +30,15 @@ import { PolygonPollingBlockService } from './polling.block/polygon.polling.bloc
           client: {
             clientId: 'worker',
             brokers: process.env.KAFKA_BROKERS.split(','),
+            ssl: process.env.KAFKA_SSL === 'true',
+            sasl:
+              process.env.KAFKA_AUTH_ENABLE === 'true'
+                ? {
+                    mechanism: 'plain',
+                    username: process.env.KAFKA_USERNAME || '',
+                    password: process.env.KAFKA_PASSWORD || '',
+                  }
+                : null,
           },
           producer: {},
           consumer: {

diff --git a/app/apps/worker-service/src/worker-service.module.ts b/app/apps/worker-service/src/worker-service.module.ts
@@ -22,6 +22,15 @@ import { PolygonWorker } from './worker/polygon.worker';
           client: {
             clientId: 'monitor',
             brokers: process.env.KAFKA_BROKERS.split(','),
+            ssl: process.env.KAFKA_SSL === 'true',
+            sasl:
+              process.env.KAFKA_AUTH_ENABLE === 'true'
+                ? {
+                    mechanism: 'plain',
+                    username: process.env.KAFKA_USERNAME || '',
+                    password: process.env.KAFKA_PASSWORD || '',
+                  }
+                : null,
           },
           producer: {},
           consumer: {