From b16270d118dc380300c4d343fe2b5420a85a400f Mon Sep 17 00:00:00 2001 From: dmitchsplunk Date: Fri, 9 May 2025 07:54:52 -0700 Subject: [PATCH] added back the kafka.js file to the otel discovery demo --- workshop/demos/otel-discovery-demo/.gitignore | 1 - .../otel-discovery-demo/src/riskservice/kafka.js | 16 ++++++++++++++++ 2 files changed, 16 insertions(+), 1 deletion(-) create mode 100644 workshop/demos/otel-discovery-demo/src/riskservice/kafka.js diff --git a/workshop/demos/otel-discovery-demo/.gitignore b/workshop/demos/otel-discovery-demo/.gitignore index 457f4600ab..8d4bfcfd89 100644 --- a/workshop/demos/otel-discovery-demo/.gitignore +++ b/workshop/demos/otel-discovery-demo/.gitignore @@ -1,2 +1 @@ -kafka* nohup.out diff --git a/workshop/demos/otel-discovery-demo/src/riskservice/kafka.js b/workshop/demos/otel-discovery-demo/src/riskservice/kafka.js new file mode 100644 index 0000000000..2adcd12aff --- /dev/null +++ b/workshop/demos/otel-discovery-demo/src/riskservice/kafka.js @@ -0,0 +1,16 @@ +const { Kafka } = require('kafkajs') + +const { KAFKA_USERNAME: username, KAFKA_PASSWORD: password } = process.env +const sasl = username && password ? { username, password, mechanism: 'plain' } : null +const ssl = !!sasl + +// This creates a client instance that is configured to connect to the Kafka broker provided by +// the environment variable KAFKA_BOOTSTRAP_SERVER +const kafka = new Kafka({ + clientId: 'risk-service', + brokers: [process.env.KAFKA_BROKER], + ssl, + sasl +}) + +module.exports = kafka