feat: added producer for kafka sample

Signed-off-by: Femi <[email protected]>

Author: FemiOfficial

examples/kafka-ex/src/admin.ts

@@ -1,3 +1,4 @@
+/* eslint-disable */
 import kafka from "./client";
 
 (async () => {

examples/kafka-ex/src/client.ts

@@ -1,3 +1,4 @@
+/* eslint-disable */
 import "dotenv/config";
 import { Kafka } from "kafkajs";
 

examples/kafka-ex/src/producer.ts

@@ -0,0 +1,40 @@
+/* eslint-disable */
+import { CloudEvent, Kafka } from "cloudevents";
+import readline from "readline";
+import kafka from "./client";
+
+const rl = readline.createInterface({
+  input: process.stdin,
+  output: process.stdout,
+});
+
+(async () => {
+  const producer = kafka.producer();
+  await producer.connect();
+
+  rl.setPrompt("> ");
+  rl.prompt();
+  rl.on("line", async (line) => {
+    const event = new CloudEvent({
+      source: "cloudevents-producer",
+      type: "events.cloudevents.test",
+      datacontenttype: "text/plain",
+      partitionkey: "1",
+      data: line,
+    });
+
+    const message = Kafka.structured(event);
+
+    console.log("Sending CloudEvent:", message);
+
+    await producer.send({
+      topic: "events.cloudevents.test",
+      messages: [message],
+    });
+    rl.prompt();
+  });
+
+  rl.on("close", async () => {
+    await producer.disconnect();
+  });
+})();

examples/kafka-ex/tsconfig.json

@@ -7,13 +7,11 @@
     "strict": true,
     "noImplicitAny": true,
     "moduleResolution": "node",
-    "esModuleInterop": true,
+    "esModuleInterop": true
   },
   "include": [
     "src/**/*.ts",
-    "src/**/*.js"
+    "src/**/*.js",
   ],
-  "exclude": [
-    "node_modules"
-  ]
-}
+  "exclude": ["node_modules"]
+}