Merge pull request #39 from mojaloop/kafka-auth

feat(nodejs-kafka-client-lib): Added authentication to kafka client (protocol config)
mojaloop · May 21, 2024 · 3471c5d · 3471c5d
2 parents 07028ca + 9a59dfa
commit 3471c5d
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 0 deletions.
diff --git a/packages/nodejs-kafka-client-lib/README.md b/packages/nodejs-kafka-client-lib/README.md
@@ -74,6 +74,7 @@ import {MLKafkaJsonProducer, MLKafkaJsonProducerOptions} from "@mojaloop/platfor
 const logger: ConsoleLogger = new ConsoleLogger();
 
 const authOptions:  IRawAuthenticationOptions = {
+    protocol: "sasl_plaintext",
     mechanism: "SCRAM-SHA-256",
     username: "kafka",
     password: "password"

diff --git a/packages/nodejs-kafka-client-lib/src/raw/raw_types.ts b/packages/nodejs-kafka-client-lib/src/raw/raw_types.ts
@@ -72,6 +72,7 @@ export declare interface IRawMessageProducer {
 }
 
 export declare interface IRawAuthenticationOptions {
+    protocol: "plaintext" | "ssl" | "sasl_plaintext" | "sasl_ssl";
     mechanism: "PLAIN" | "GSSAPI" | "SCRAM-SHA-256" | "SCRAM-SHA-512",
     username: string,
     password: string

diff --git a/packages/nodejs-kafka-client-lib/src/raw/rdkafka_raw_consumer.ts b/packages/nodejs-kafka-client-lib/src/raw/rdkafka_raw_consumer.ts
@@ -198,6 +198,7 @@ export class MLKafkaRawConsumer extends EventEmitter implements IRawMessageConsu
 
         // authentication options
         if(this._options.authentication != undefined) {
+            this._globalConfig["security.protocol"] = this._options.authentication.protocol;
             this._globalConfig["sasl.mechanism"] = this._options.authentication.mechanism;
             this._globalConfig["sasl.username"] = this._options.authentication.username;
             this._globalConfig["sasl.password"] = this._options.authentication.password;

diff --git a/packages/nodejs-kafka-client-lib/src/raw/rdkafka_raw_producer.ts b/packages/nodejs-kafka-client-lib/src/raw/rdkafka_raw_producer.ts
@@ -165,6 +165,7 @@ export class MLKafkaRawProducer extends EventEmitter implements IRawMessageProdu
 
         // authentication options
         if(this._options.authentication != undefined) {
+            this._globalConfig["security.protocol"] = this._options.authentication.protocol;
             this._globalConfig["sasl.mechanism"] = this._options.authentication.mechanism;
             this._globalConfig["sasl.username"] = this._options.authentication.username;
             this._globalConfig["sasl.password"] = this._options.authentication.password;