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