kafkajs - npm Package Compare versions

Comparing version 2.1.0-beta.9 to 2.1.0-beta.10

package.json

 {
   "name": "kafkajs",
-  "version": "2.1.0-beta.9",
+  "version": "2.1.0-beta.10",
   "description": "A modern Apache Kafka client for node.js",
@@ -85,5 +85,5 @@ "author": "Tulio Ornelas <[e-mail]>",
   "kafkajs": {
-    "sha": "196105c224353113ae3e7f8ef54ac9bad9951143",
-    "compare": "https://github.com/tulios/kafkajs/compare/v2.0.2...196105c224353113ae3e7f8ef54ac9bad9951143"
+    "sha": "48b8bc72512d94331790712c22382b449e906445",
+    "compare": "https://github.com/tulios/kafkajs/compare/v2.0.2...48b8bc72512d94331790712c22382b449e906445"
   }
 }

types/index.d.ts

@@ -634,12 +634,24 @@ /// <reference types="node" />
 
-export type KafkaMessage = {
+interface MessageSetEntry {
   key: Buffer | null
   value: Buffer | null
   timestamp: string
+  attributes: number
+  offset: string
   size: number
+  headers?: never
+}
+
+interface RecordBatchEntry {
+  key: Buffer | null
+  value: Buffer | null
+  timestamp: string
   attributes: number
   offset: string
-  headers?: IHeaders
+  headers: IHeaders
+  size?: never
 }
 
+export type KafkaMessage = MessageSetEntry | RecordBatchEntry
+
 export interface ProducerRecord {
@@ -646,0 +658,0 @@ topic: string

No alert changes

Improved metrics

Total package byte prevSize

713201

increased by0.03%

Lines of code

20796

increased by0.05%

No dependency changes