kafkajs - npm Package Compare versions

Comparing version 1.16.0-beta.30 to 1.16.0-beta.31

package.json

 {
   "name": "kafkajs",
-  "version": "1.16.0-beta.30",
+  "version": "1.16.0-beta.31",
   "description": "A modern Apache Kafka client for node.js",
@@ -83,5 +83,5 @@ "author": "Tulio Ornelas <[e-mail]>",
   "kafkajs": {
-    "sha": "38e075000931dd490761a42c2c9157e585cb1469",
-    "compare": "https://github.com/tulios/kafkajs/compare/v1.15.0...38e075000931dd490761a42c2c9157e585cb1469"
+    "sha": "2b5f96fe1f3d005f27b5807e4a0934414fef971d",
+    "compare": "https://github.com/tulios/kafkajs/compare/v1.15.0...2b5f96fe1f3d005f27b5807e4a0934414fef971d"
   }
 }

src/consumer/runner.js

@@ -151,3 +151,10 @@ const { EventEmitter } = require('events')
       try {
-        await this.eachMessage({ topic, partition, message })
+        await this.eachMessage({
+          topic,
+          partition,
+          message,
+          heartbeat: async () => {
+            await this.consumerGroup.heartbeat({ interval: this.heartbeatInterval })
+          },
+        })
       } catch (e) {
@@ -154,0 +161,0 @@ if (!isKafkaJSError(e)) {

types/index.d.ts

@@ -861,2 +861,3 @@ /// <reference types="node" />
   message: KafkaMessage
+  heartbeat(): Promise<void>
 }
@@ -886,2 +887,5 @@
 
+export type EachBatchHandler = (payload: EachBatchPayload) => Promise<void>
+export type EachMessageHandler = (payload: EachMessagePayload) => Promise<void>
+
 export type ConsumerRunConfig = {
@@ -893,4 +897,4 @@ autoCommit?: boolean
   partitionsConsumedConcurrently?: number
-  eachBatch?: (payload: EachBatchPayload) => Promise<void>
-  eachMessage?: (payload: EachMessagePayload) => Promise<void>
+  eachBatch?: EachBatchHandler
+  eachMessage?: EachMessageHandler
 }
@@ -897,0 +901,0 @@

No alert changes

Improved metrics

Total package byte prevSize

696345

increased by0.04%

Lines of code

20431

increased by0.05%

No dependency changes