chore: add seek and commit method to KafkaStreamReadable

Cargo.toml

@@ -1,7 +1,7 @@
 [package]
 edition = "2021"
 name = "kafka-crab-js"
-version = "0.0.0"
+version = "1.0.0"
 
 [lib]
 crate-type = ["cdylib"]

example/stream-sample.mjs

@@ -1,5 +1,5 @@
 import { fakerPT_BR } from '@faker-js/faker'
-import { KafkaClient } from '../index.js'
+import { KafkaClient, PartitionPosition } from '../index.js'
 
 const kafkaClient = new KafkaClient({
   brokers: 'localhost:29092',
@@ -39,7 +39,7 @@ async function startConsumer(topic) {
     enableAutoCommit: true,
   })
 
-  await kafkaStream.subscribe(topic)
+  await kafkaStream.subscribe([{ topic: 'foo', allOffsets: { position: PartitionPosition.Beginning } }])
 
   let counter = 0
   console.log('Starting consumer')

js-src/kafka-stream-readable.ts

@@ -1,6 +1,7 @@
 import { Readable } from 'stream'
 
-import { KafkaConsumer, TopicPartitionConfig } from './js-binding'
+import { CommitMode } from '../js-binding'
+import { KafkaConsumer, OffsetModel, TopicPartitionConfig } from './js-binding'
 
 /**
  * KafkaStreamReadable class
@@ -28,6 +29,14 @@ export class KafkaStreamReadable extends Readable {
     await this.kafkaConsumer.subscribe(topics)
   }
 
+  seek(topic: string, partition: number, offsetModel: OffsetModel, timeout?: number | undefined) {
+    this.kafkaConsumer.seek(topic, partition, offsetModel, timeout)
+  }
+
+  commit(topic: string, partition: number, offset: number, commit: CommitMode) {
+    this.kafkaConsumer.commit(topic, partition, offset, commit)
+  }
+
   /**
    * Unsubscribe from topics
    */

kafka-stream-readable.d.ts

@@ -1,5 +1,6 @@
 import { Readable } from 'stream';
-import { KafkaConsumer, TopicPartitionConfig } from './js-binding';
+import { CommitMode } from '../js-binding';
+import { KafkaConsumer, OffsetModel, TopicPartitionConfig } from './js-binding';
 /**
  * KafkaStreamReadable class
  * @extends Readable
@@ -14,6 +15,8 @@ export declare class KafkaStreamReadable extends Readable {
      * Subscribes to topics
      */
     subscribe(topics: string | Array<TopicPartitionConfig>): Promise<void>;
+    seek(topic: string, partition: number, offsetModel: OffsetModel, timeout?: number | undefined): void;
+    commit(topic: string, partition: number, offset: number, commit: CommitMode): void;
     /**
      * Unsubscribe from topics
      */

kafka-stream-readable.js

@@ -27,6 +27,12 @@ class KafkaStreamReadable extends stream_1.Readable {
         }
         await this.kafkaConsumer.subscribe(topics);
     }
+    seek(topic, partition, offsetModel, timeout) {
+        this.kafkaConsumer.seek(topic, partition, offsetModel, timeout);
+    }
+    commit(topic, partition, offset, commit) {
+        this.kafkaConsumer.commit(topic, partition, offset, commit);
+    }
     /**
      * Unsubscribe from topics
      */

package.json

@@ -1,6 +1,6 @@
 {
   "name": "kafka-crab-js",
-  "version": "1.0.3",
+  "version": "1.0.4",
   "main": "index.js",
   "types": "index.d.ts",
   "module": "commonjs",
@@ -40,13 +40,13 @@
     "url": "https://github.com/inaiat/kafka-crab-js.git"
   },
   "devDependencies": {
-    "@faker-js/faker": "9.2.0",
+    "@faker-js/faker": "9.3.0",
     "@napi-rs/cli": "^2.18.4",
-    "@types/node": "22.9.0",
+    "@types/node": "22.10.1",
     "ava": "6.2.0",
-    "dprint": "^0.47.5",
-    "nanoid": "5.0.8",
-    "typescript": "5.6.3",
+    "dprint": "^0.47.6",
+    "nanoid": "5.0.9",
+    "typescript": "5.7.2",
     "copyfiles": "^2.4.1",
     "@types/copyfiles": "^2.4.4",
     "rimraf": "^6.0.1"