From be85ebef216024f1e3f5c99b88ee53cff3bea156 Mon Sep 17 00:00:00 2001
From: "Luiz F. Picolo" <luizpicolo@gmail.com>
Date: Fri, 26 May 2023 10:07:44 -0400
Subject: [PATCH] Adicionado REadme

---
 README.md         |  1 +
 consumer.js       | 15 ---------------
 package-lock.json |  2 +-
 package.json      |  2 +-
 producer.js       | 15 ---------------
 yarn.lock         |  2 +-
 6 files changed, 4 insertions(+), 33 deletions(-)
 create mode 100644 README.md

diff --git a/README.md b/README.md
new file mode 100644
index 0000000..557db03
--- /dev/null
+++ b/README.md
@@ -0,0 +1 @@
+Hello World
diff --git a/consumer.js b/consumer.js
index 68a250c..6479b1d 100644
--- a/consumer.js
+++ b/consumer.js
@@ -5,19 +5,9 @@ const kafka = new Kafka({
   brokers: ['localhost:9092']
 })
 
-//const producer = kafka.producer()
 const consumer = kafka.consumer({ groupId: 'test-group' })
 
 const run = async () => {
-  // // Producing
-  // await producer.connect()
-  // await producer.send({
-  //   topic: 'test-topic',
-  //   messages: [
-  //     { value: 'Hello KafkaJS user!' },
-  //   ],
-  // })
-
   // Consuming
   await consumer.connect()
   await consumer.subscribe({ topic: process.env.TOPIC, fromBeginning: true })
@@ -27,11 +17,6 @@ const run = async () => {
       const obj = JSON.parse(message.value)
       console.log('Message consumer successfully!');
       console.log(obj.name)
-      // console.log({
-      //   partition,
-      //   offset: message.offset,
-      //   value: Json.parse(message.value),
-      // })
     },
     
   })
diff --git a/package-lock.json b/package-lock.json
index 0b5671a..d79fff1 100644
--- a/package-lock.json
+++ b/package-lock.json
@@ -5,7 +5,7 @@
   "packages": {
     "": {
       "dependencies": {
-        "kafkajs": "^2.2.2"
+        "kafkajs": "^2.2.4"
       }
     },
     "node_modules/kafkajs": {
diff --git a/package.json b/package.json
index 75648fe..6579aae 100644
--- a/package.json
+++ b/package.json
@@ -1,5 +1,5 @@
 {
   "dependencies": {
-    "kafkajs": "^2.2.2"
+    "kafkajs": "^2.2.4"
   }
 }
diff --git a/producer.js b/producer.js
index 6a8612b..219a37f 100644
--- a/producer.js
+++ b/producer.js
@@ -30,21 +30,6 @@ const run = async () => {
   } finally {
     await producer.disconnect();
   }
-
-  // Consuming
-  // await consumer.connect()
-  // await consumer.subscribe({ topic: 'test-topic', fromBeginning: true })
-
-  // await consumer.run({
-  //   eachMessage: async ({ topic, partition, message }) => {
-  //     console.log({
-  //       partition,
-  //       offset: message.offset,
-  //       value: message.value.toString(),
-  //     })
-  //   },
-    
-  // })
 }
 
 run()
\ No newline at end of file
diff --git a/yarn.lock b/yarn.lock
index cd5f22b..bdcdb06 100644
--- a/yarn.lock
+++ b/yarn.lock
@@ -2,7 +2,7 @@
 # yarn lockfile v1
 
 
-"kafkajs@^2.2.2":
+"kafkajs@^2.2.4":
   "integrity" "sha512-j/YeapB1vfPT2iOIUn/vxdyKEuhuY2PxMBvf5JWux6iSaukAccrMtXEY/Lb7OvavDhOWME589bpLrEdnVHjfjA=="
   "resolved" "https://registry.npmjs.org/kafkajs/-/kafkajs-2.2.4.tgz"
   "version" "2.2.4"