piyushgarg-dev · November 1, 2025 17:49 · Jul 29, 2023 · Jul 29, 2023 · Jul 29, 2023 · Jul 29, 2023
diff --git a/README.md b/README.md
@@ -3,7 +3,7 @@ Video Link: [Apache Kafka Crash Course | What is Kafka?](https://youtu.be/ZJJHm_
 ## Prerequisite
 - Knowledge
   - Node.JS Intermediate level
-  - Experince with designing distributed systems
+  - Experience with designing distributed systems
 - Tools
   - Node.js: [Download Node.JS](https://nodejs.org/en)
   - Docker: [Download Docker](https://www.docker.com)

diff --git a/README.md b/README.md
@@ -30,7 +30,7 @@ const { Kafka } = require("kafkajs");
 
 exports.kafka = new Kafka({
   clientId: "my-app",
-  brokers: ["192.168.29.35:9092"],
+  brokers: ["<PRIVATE_IP>:9092"],
 });
 
 ```

diff --git a/README.md b/README.md
@@ -1,5 +1,5 @@
 # Kafka
-
+Video Link: [Apache Kafka Crash Course | What is Kafka?](https://youtu.be/ZJJHm_bd9Zo)
 ## Prerequisite
 - Knowledge
   - Node.JS Intermediate level

diff --git a/README.md b/README.md
@@ -122,4 +122,17 @@ async function init() {
 }
 
 init();
+```
+## Running Locally
+- Run Multiple Consumers
+```bash
+node consumer.js <GROUP_NAME>
+```
+- Create Producer
+```bash
+node producer.js
+```
+```bash
+> tony south
+> tony north
 ```
diff --git a/README.md b/README.md
@@ -21,4 +21,105 @@ docker run -p 9092:9092 \
 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://<PRIVATE_IP>:9092 \
 -e KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR=1 \
 confluentinc/cp-kafka
+```
+
+## Code
+`client.js`
+```js
+const { Kafka } = require("kafkajs");
+
+exports.kafka = new Kafka({
+  clientId: "my-app",
+  brokers: ["192.168.29.35:9092"],
+});
+
+```
+`admin.js`
+```js
+const { kafka } = require("./client");
+
+async function init() {
+  const admin = kafka.admin();
+  console.log("Admin connecting...");
+  admin.connect();
+  console.log("Adming Connection Success...");
+
+  console.log("Creating Topic [rider-updates]");
+  await admin.createTopics({
+    topics: [
+      {
+        topic: "rider-updates",
+        numPartitions: 2,
+      },
+    ],
+  });
+  console.log("Topic Created Success [rider-updates]");
+
+  console.log("Disconnecting Admin..");
+  await admin.disconnect();
+}
+
+init();
+```
+`producer.js`
+```js
+const { kafka } = require("./client");
+const readline = require("readline");
+
+const rl = readline.createInterface({
+  input: process.stdin,
+  output: process.stdout,
+});
+
+async function init() {
+  const producer = kafka.producer();
+
+  console.log("Connecting Producer");
+  await producer.connect();
+  console.log("Producer Connected Successfully");
+
+  rl.setPrompt("> ");
+  rl.prompt();
+
+  rl.on("line", async function (line) {
+    const [riderName, location] = line.split(" ");
+    await producer.send({
+      topic: "rider-updates",
+      messages: [
+        {
+          partition: location.toLowerCase() === "north" ? 0 : 1,
+          key: "location-update",
+          value: JSON.stringify({ name: riderName, location }),
+        },
+      ],
+    });
+  }).on("close", async () => {
+    await producer.disconnect();
+  });
+}
+
+init();
+```
+`consumer.js`
+```js
+const { kafka } = require("./client");
+const group = process.argv[2];
+
+async function init() {
+  const consumer = kafka.consumer({ groupId: group });
+  await consumer.connect();
+
+  await consumer.subscribe({ topics: ["rider-updates"], fromBeginning: true });
+
+  await consumer.run({
+    eachMessage: async ({ topic, partition, message, heartbeat, pause }) => {
+      console.log(
+        `${group}: [${topic}]: PART:${partition}:`,
+        message.value.toString()
+      );
+    },
+  });
+}
+
+init();
 ```
diff --git a/README.md b/README.md
@@ -19,6 +19,6 @@ docker run -p 2181:2181 zookeeper
 docker run -p 9092:9092 \
 -e KAFKA_ZOOKEEPER_CONNECT=<PRIVATE_IP>:2181 \
 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://<PRIVATE_IP>:9092 \
--e KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR=1
-confluentic/cp-kafka
+-e KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR=1 \
+confluentinc/cp-kafka
 ```
diff --git a/README.md b/README.md
@@ -10,7 +10,15 @@
   - VsCode: [Download VSCode](https://code.visualstudio.com)
 
 ## Commands
-- Start Zookeper Container and expose PORT `2181`
+- Start Zookeper Container and expose PORT `2181`.
 ```bash
 docker run -p 2181:2181 zookeeper
+```
+- Start Kafka Container, expose PORT `9092` and setup ENV variables.
+```bash
+docker run -p 9092:9092 \
+-e KAFKA_ZOOKEEPER_CONNECT=<PRIVATE_IP>:2181 \
+-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://<PRIVATE_IP>:9092 \
+-e KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR=1
+confluentic/cp-kafka
 ```
diff --git a/README.md b/README.md
@@ -7,4 +7,10 @@
 - Tools
   - Node.js: [Download Node.JS](https://nodejs.org/en)
   - Docker: [Download Docker](https://www.docker.com)
-  - VsCode: [Download VSCode](https://code.visualstudio.com)
+  - VsCode: [Download VSCode](https://code.visualstudio.com)
+
+## Commands
+- Start Zookeper Container and expose PORT `2181`
+```bash
+docker run -p 2181:2181 zookeeper
+```
diff --git a/README.md b/README.md
@@ -0,0 +1,10 @@
+# Kafka
+
+## Prerequisite
+- Knowledge
+  - Node.JS Intermediate level
+  - Experince with designing distributed systems
+- Tools
+  - Node.js: [Download Node.JS](https://nodejs.org/en)
+  - Docker: [Download Docker](https://www.docker.com)
+  - VsCode: [Download VSCode](https://code.visualstudio.com)