Merge pull request #1226 from moleculerjs/kafkajs

Using `kafkajs` library in Kafka transporter
moleculerjs · Jul 16, 2023 · f11f772 · f11f772
2 parents da81b90 + 43af200
commit f11f772
Show file tree

Hide file tree

Showing 9 changed files with 406 additions and 1,560 deletions.
diff --git a/dev/client.js b/dev/client.js
@@ -21,9 +21,9 @@ const broker = new ServiceBroker({
 		}
 	},
 	*/
-	//transporter: "kafka://192.168.0.181:9092",
+	transporter: "kafka://127.0.0.1:9093",
 	//transporter: "amqp://192.168.0.181:5672",
-	transporter: "NATS",
+	//transporter: "NATS",
 	//serializer: "MsgPack",
 	//requestTimeout: 1000,
 
@@ -34,7 +34,7 @@ const broker = new ServiceBroker({
 		//discoverer: "Etcd3"
 	},
 
-	cacher: true,
+	//cacher: true,
 
 	metrics: {
 		enabled: false,
@@ -80,8 +80,8 @@ const broker = new ServiceBroker({
 	logger: console,
 	logLevel: "info",
 	middlewares: [
-		//Middlewares.Transmit.Encryption("moleculer", "aes-256-cbc"),
-		//Middlewares.Transmit.Compression(),
+		// Middlewares.Transmit.Encryption("moleculer", "aes-256-cbc"),
+		// Middlewares.Transmit.Compression()
 		//Middlewares.Debugging.TransitLogger({ logPacketData: false, /*folder: null, colors: { send: "magenta", receive: "blue"}*/ }),
 		//Middlewares.Debugging.ActionLogger({ logParams: true, logResponse: true, /*folder: null, colors: { send: "magenta", receive: "blue"}*/ }),
 		//require("./RedisHeartbeat")

diff --git a/dev/server.js b/dev/server.js
@@ -20,10 +20,10 @@ const broker = new ServiceBroker({
 		}
 	},
 	*/
-	//transporter: "kafka://localhost:9093",
+	transporter: "kafka://localhost:9093",
 	//transporter: "amqp://192.168.0.181:5672",
 	//transporter: "AMQP10",
-	transporter: "NATS",
+	//transporter: "NATS",
 	//serializer: "MsgPack",
 
 	//disableBalancer: true,
@@ -63,8 +63,8 @@ const broker = new ServiceBroker({
 	logLevel: "info",
 
 	middlewares: [
-		//Middlewares.Transmit.Encryption("moleculer", "aes-256-cbc"),
-		//Middlewares.Transmit.Compression(),
+		// Middlewares.Transmit.Encryption("moleculer", "aes-256-cbc"),
+		// Middlewares.Transmit.Compression()
 		//Middlewares.Debugging.TransitLogger({ logPacketData: false, /*folder: null, colors: { send: "magenta", receive: "blue"}*/ }),
 		//Middlewares.Debugging.ActionLogger({ logPacketData: false, /*folder: null, colors: { send: "magenta", receive: "blue"}*/ }),
 		//require("./RedisHeartbeat")

diff --git a/examples/.eslintrc.js b/examples/.eslintrc.js
@@ -13,6 +13,7 @@ module.exports = {
 		"no-var": ["warn"],
 		"no-console": ["off"],
 		"no-unused-vars": ["off"],
+		"no-mixed-spaces-and-tabs": ["off"],
 		"security/detect-possible-timing-attacks": ["off"]
 	}
 };
diff --git a/examples/opentelemetry/opentelemetry.middleware.js b/examples/opentelemetry/opentelemetry.middleware.js
@@ -40,14 +40,15 @@ module.exports = {
 					delete ctx.meta.$otel;
 				}
 
+				const actionObj = ctx.action
+					? {
+							name: ctx.action.name,
+							rawName: ctx.action.rawName
+					  }
+					: null;
 				let tags = {
 					callingLevel: ctx.level,
-					action: ctx.action
-						? {
-								name: ctx.action.name,
-								rawName: ctx.action.rawName
-						  }
-						: null,
+					action: actionObj,
 					remoteCall: ctx.nodeID !== ctx.broker.nodeID,
 					callerNodeID: ctx.nodeID,
 					nodeID: ctx.broker.nodeID,