limit the amount of data from kafka to 1

src/index.ts

@@ -35,7 +35,7 @@ kafka.init().then(() => {
     const next = () => {
       index = setInterval(() => {
         // start consuming
-        consumer.consume(100);
+        consumer.consume(1);
       }, 1);
     };
     next();