feat: added client and admin for kafka topics

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

Author: FemiOfficial

examples/kafka-ex/src/admin.ts

@@ -0,0 +1,15 @@
+import kafka from "./client";
+
+(async () => {
+  const admin = kafka.admin();
+  await admin.connect();
+  await admin.createTopics({
+    topics: [
+      {
+        topic: "events.cloudevents.test",
+        numPartitions: 2,
+      },
+    ],
+  });
+  await admin.disconnect();
+})();

examples/kafka-ex/src/client.ts

@@ -0,0 +1,9 @@
+import "dotenv/config";
+import { Kafka } from "kafkajs";
+
+const kafka = new Kafka({
+  clientId: 'kafka-ex-client-id',
+  brokers: ['localhost:9092'],
+});
+
+export default kafka;

examples/kafka-ex/tsconfig.json

@@ -0,0 +1,19 @@
+{
+  "compilerOptions": {
+    "target": "ES2020",
+    "module": "commonjs",
+    "allowJs": true,
+    "checkJs": false,
+    "strict": true,
+    "noImplicitAny": true,
+    "moduleResolution": "node",
+    "esModuleInterop": true,
+  },
+  "include": [
+    "src/**/*.ts",
+    "src/**/*.js"
+  ],
+  "exclude": [
+    "node_modules"
+  ]
+}