Comparing version 2.5.0 to 2.5.1
@@ -171,3 +171,3 @@ 'use strict'; | ||
(0, _logger.log)('Consuming ' + topic + ' at offset ' + offset); | ||
(0, _logger.log)('Consuming ' + topic + ' at offset ' + offset + ', using command: ' + _run.kafkacat); | ||
var consumer = spawn(_run.kafkacat, consume_options); | ||
@@ -174,0 +174,0 @@ |
{ | ||
"name": "elytron", | ||
"version": "2.5.0", | ||
"version": "2.5.1", | ||
"description": "An interface for Kafka in Node", | ||
@@ -5,0 +5,0 @@ "main": "./dist/src/index.js", |
@@ -164,3 +164,3 @@ import uuid from 'uuid'; | ||
log(`Consuming ${topic} at offset ${offset}`); | ||
log(`Consuming ${topic} at offset ${offset}, using command: ${kafkacat}`); | ||
const consumer = spawn(kafkacat, consume_options); | ||
@@ -167,0 +167,0 @@ |
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
42118