kafkajs-stream
Advanced tools
Comparing version 0.0.4 to 0.0.5
@@ -5,2 +5,9 @@ # Changelog | ||
### [0.0.5](https://github.com/kambing86/kafkajs-stream/compare/v0.0.4...v0.0.5) (2019-12-16) | ||
### Bug Fixes | ||
* add consumer.crash error handling ([bd62a02](https://github.com/kambing86/kafkajs-stream/commit/bd62a02c491ffa071700ba4261b6ba18dd4a892a)) | ||
### [0.0.4](https://github.com/kambing86/kafkajs-stream/compare/v0.0.3...v0.0.4) (2019-12-13) | ||
@@ -7,0 +14,0 @@ |
@@ -29,2 +29,5 @@ "use strict"; | ||
yield this.consumer.subscribe(this.topic); | ||
this.consumer.on("consumer.crash", err => { | ||
this.destroy(err); | ||
}); | ||
} | ||
@@ -31,0 +34,0 @@ if (!this.started) { |
{ | ||
"name": "kafkajs-stream", | ||
"version": "0.0.4", | ||
"version": "0.0.5", | ||
"description": "Stream for kafkajs", | ||
@@ -5,0 +5,0 @@ "main": "dist/index.js", |
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
14809
177