kafkajs-stream - npm Package Compare versions

Comparing version 0.0.10 to 0.0.11

CHANGELOG.md

@@ -5,2 +5,9 @@ # Changelog
 
+### [0.0.11](https://github.com/kambing86/kafkajs-stream/compare/v0.0.10...v0.0.11) (2020-01-07)
+
+
+### Bug Fixes
+
+* fix type definitions ([ea4d8fd](https://github.com/kambing86/kafkajs-stream/commit/ea4d8fdaa66cd8748442ac955ecbd74bda01fde3))
+
 ### [0.0.10](https://github.com/kambing86/kafkajs-stream/compare/v0.0.9...v0.0.10) (2019-12-20)
@@ -7,0 +14,0 @@

dist/ConsumerObjectStream.d.ts

 /// <reference types="node" />
-import { ConsumerConfig, Kafka } from 'kafkajs';
+import { ConsumerConfig, Kafka, KafkaMessage } from 'kafkajs';
 import { Readable } from 'stream';
@@ -11,3 +11,3 @@ interface ConsumerObjectStreamOptions {
     highWaterMark?: number;
-    transform?: (data: any) => any;
+    transform?: (data: KafkaMessage) => any;
 }
@@ -14,0 +14,0 @@ export declare class ConsumerObjectStream extends Readable {

dist/ProducerObjectStream.d.ts

@@ -11,3 +11,3 @@ /// <reference types="node" />
     highWaterMark?: number;
-    transform?: (data: any) => any;
+    transform?: (data: any) => Message;
 }
@@ -20,3 +20,3 @@ export declare class ProducerObjectStream extends Writable {
     _writev(chunks: {
-        chunk: Message;
+        chunk: any;
         encoding: string;
@@ -23,0 +23,0 @@ }[], callback: (error?: Error | null) => void): void;

module/ConsumerObjectStream.d.ts

 /// <reference types="node" />
-import { ConsumerConfig, Kafka } from 'kafkajs';
+import { ConsumerConfig, Kafka, KafkaMessage } from 'kafkajs';
 import { Readable } from 'stream';
@@ -11,3 +11,3 @@ interface ConsumerObjectStreamOptions {
     highWaterMark?: number;
-    transform?: (data: any) => any;
+    transform?: (data: KafkaMessage) => any;
 }
@@ -14,0 +14,0 @@ export declare class ConsumerObjectStream extends Readable {

module/ProducerObjectStream.d.ts

@@ -11,3 +11,3 @@ /// <reference types="node" />
     highWaterMark?: number;
-    transform?: (data: any) => any;
+    transform?: (data: any) => Message;
 }
@@ -20,3 +20,3 @@ export declare class ProducerObjectStream extends Writable {
     _writev(chunks: {
-        chunk: Message;
+        chunk: any;
         encoding: string;
@@ -23,0 +23,0 @@ }[], callback: (error?: Error | null) => void): void;

package.json

 {
   "name": "kafkajs-stream",
-  "version": "0.0.10",
+  "version": "0.0.11",
   "description": "Stream for kafkajs",
@@ -11,3 +11,6 @@ "main": "dist/index.js",
     "build:strict": "tsc --declaration --noImplicitAny && tsc --declaration -p tsconfig-module.json --noImplicitAny",
-    "release": "standard-version"
+    "prerelease": "yarn build",
+    "release": "standard-version",
+    "prettier": "prettier --check 'src/**/*.*'",
+    "prettier:write": "prettier --write 'src/**/*.*'"
   },
@@ -33,7 +36,7 @@ "repository": {
   "devDependencies": {
-    "@types/node": "^12.12.17",
+    "@types/node": "^13.1.4",
     "kafkajs": "^1.11.0",
     "prettier": "^1.19.1",
     "standard-version": "^7.0.1",
-    "typescript": "^3.7.3"
+    "typescript": "^3.7.4"
   },
@@ -40,0 +43,0 @@ "files": [

No alert changes

Improved metrics

Total package byte prevSize

47041

increased by0.83%

No dependency changes