Merge pull request #374 from dmitchsplunk/main

added back the kafka.js file to the otel discovery demo

Author: dmitchsplunk

workshop/demos/otel-discovery-demo/.gitignore

@@ -1,2 +1 @@
-kafka*
 nohup.out

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