elytron - npm Package Compare versions

Comparing version 2.2.5 to 2.2.7

dist/src/consume/index.js

		@@ -152,2 +152,3 @@ 'use strict';
		var stdout = '';
		var stale_cache_timer = void 0;

		@@ -158,4 +159,8 @@ (0, _logger.log)('Consuming ' + topic + ' at offset ' + offset);
		consumer.stdout.on('data', function (data) {
		clearTimeout(stale_cache_timer);
		stdout += data.toString();
		stdout = handle_consumer_data(stdout, topic, id, work, exit);
		stale_cache_timer = setTimeout(function () {
		return stdout = '';
		}, process.env.STALE_CACHE_TIMER \|\| 3600000);
		});
		@@ -162,0 +167,0 @@ consumer.stderr.on('data', function (data) {

package.json

		{
		"name": "elytron",
		"version": "2.2.5",
		"version": "2.2.7",
		"description": "An interface for Kafka in Node",
		@@ -5,0 +5,0 @@ "main": "./dist/src/index.js",

src/consume/index.js

		@@ -138,2 +138,3 @@ import uuid from 'uuid';
		let stdout = '';
		let stale_cache_timer;

		@@ -144,4 +145,9 @@ log(`Consuming ${topic} at offset ${offset}`);
		consumer.stdout.on('data', (data) => {
		clearTimeout(stale_cache_timer);
		stdout += data.toString();
		stdout = handle_consumer_data(stdout, topic, id, work, exit);
		stale_cache_timer = setTimeout(
		() => stdout = '',
		process.env.STALE_CACHE_TIMER \|\| 3600000
		);
		});
		@@ -148,0 +154,0 @@ consumer.stderr.on('data', (data) => {

out.log

New alerts