try to fix node example

infinyon · Mar 7, 2023 · baa7ef3 · baa7ef3
1 parent bc3db67
commit baa7ef3
Showing 1 changed file with 14 additions and 2 deletions.
diff --git a/embeds/client-examples/node/example.ts b/embeds/client-examples/node/example.ts
@@ -33,6 +33,9 @@ const produce = async () => {
   console.log("Connecting client to fluvio");
   await fluvio.connect();
 
+  await delay(500);
+  console.log("producing record");
+
   // Create a topic producer;
   const producer = await fluvio.topicProducer(TOPIC_NAME);
   await producer.send("example-key", "Hello World!  - Time is " + Date());
@@ -43,11 +46,13 @@ const consume = async () => {
     // Connect to the fluvio cluster referenced in the cli profile.
     await fluvio.connect();
 
+    await delay(1000);
+
     // Create partition consumer
     const consumer = await fluvio.partitionConsumer(TOPIC_NAME, PARTITION);
 
-    console.log("read from the end");
-    await consumer.stream(Offset.FromEnd(), async (record: Record) => {
+    console.log("read from beginning");
+    await consumer.stream(Offset.FromBeginning(), async (record: Record) => {
       // handle record;
       console.log(`Key=${record.keyString()}, Value=${record.valueString()}`);
       process.exit(0);
@@ -57,9 +62,16 @@ const consume = async () => {
   }
 };
 
+function delay(ms: number) {
+  return new Promise(resolve => setTimeout(resolve, ms));
+}
+
+
 // Create Fluvio Client Instance
 const fluvio = new Fluvio();
 createTopic();
+
+
 produce();
 consume();