Rama sad

consumer/Dockerfile

@@ -0,0 +1,13 @@
+FROM alpine
+
+RUN apk update && apk add nodejs
+
+RUN apk update && apk add git
+
+RUN apk update && apk add python3
+
+COPY . /consumer
+
+WORKDIR /consumer
+
+CMD [ "node","consumer.js" ]

consumer.js → consumer/consumer.js

@@ -19,6 +19,7 @@ const main = async () => {
 
    await consumer.run({
       eachMessage: async ({ message }) => {
+         console.log("Trabajo recibido")
          const addr = message.value.toString().slice(1,-1)
          const auth = message.key.toString()
 

consumer/kafka.js

@@ -0,0 +1,18 @@
+const { Kafka } = require('kafkajs')
+const brokers = [process.env.KAFKA_BROKER_SERVER]
+const clientId = process.env.KEYCLOAK_CLIENTID
+const username = ''
+const password = ''
+
+const sasl = username && password ? { username, password, mechanism: 'plain' } : null
+const ssl = !!sasl
+
+const kafka = new Kafka({ clientId, brokers /*ssl sasl*/ })
+
+/*
+const groupId= 'Grupo'
+const producer = kafka.producer()
+const consumer = kafka.consumer({ groupId })
+const admin = kafka.admin()
+*/
+module.exports = kafka