steveo - npm Package Compare versions

Comparing version 5.0.0-beta2.1 to 5.0.0-beta2.2

lib/common.d.ts

@@ -33,2 +33,3 @@ import { HTTPOptions } from 'aws-sdk';
     defaultTopicPartitions?: number;
+    debug?: string;
     defaultTopicReplicationFactor?: number;
@@ -35,0 +36,0 @@ /**

lib/runner/kafka.js

@@ -149,3 +149,3 @@ "use strict";
         this.logger = (_a = steveo === null || steveo === void 0 ? void 0 : steveo.logger) !== null && _a !== void 0 ? _a : null_logger_1.default;
-        this.consumer = new node_rdkafka_1.default.KafkaConsumer(Object.assign({ 'bootstrap.servers': this.config.bootstrapServers, 'security.protocol': this.config.securityProtocol, offset_commit_cb: (err, topicPartitions) => {
+        this.consumer = new node_rdkafka_1.default.KafkaConsumer(Object.assign({ 'bootstrap.servers': this.config.bootstrapServers, 'security.protocol': this.config.securityProtocol, debug: this.config.debug, offset_commit_cb: (err, topicPartitions) => {
                 if (err) {
@@ -187,2 +187,5 @@ this.logger.error(err);
             });
+            this.consumer.on('event.log', log => {
+                this.logger.debug(log.message);
+            });
             this.consumer.on('disconnected', () => {
@@ -189,0 +192,0 @@ this.logger.debug('Consumer disconnected');

package.json

 {
   "name": "steveo",
-  "version": "5.0.0-beta2.1",
+  "version": "5.0.0-beta2.2",
   "description": "A Task Pub/Sub Background processing library",
@@ -5,0 +5,0 @@ "main": "lib/index.js",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

93391

increased by0.17%

Lines of code

1957

increased by0.2%

No dependency changes