elytron - npm Package Compare versions

Comparing version 2.4.0 to 2.5.0

dist/src/produce/index.js

		@@ -29,3 +29,3 @@ 'use strict';

		var await_response = function await_response(topic, id, work, broker_list) {
		var await_response = function await_response(topic, id, work) {
		var offset = 1; // Skip the initial message which creates the topic
		@@ -42,3 +42,5 @@ var exit = true; // Cleanup when we've received our response

		var handle_producer_error = function handle_producer_error(data) {
		var handle_producer_error = function handle_producer_error(data, callback) {
		var error_string = 'Producer logged an error: ' + data.toString();
		if (callback) return (0, _logger.error)(error_string);
		throw new _error.BrokerError('Producer logged an error: ' + data.toString());
		@@ -66,3 +68,5 @@ };
		producer.stdout.on('data', handle_producer_data);
		producer.stderr.on('data', handle_producer_error);
		producer.stderr.on('data', function (data) {
		return handle_producer_error(data, callback);
		});
		producer.on('close', function (code) {
		@@ -86,3 +90,3 @@ return handle_producer_close(code, message_file_path, callback);
		if (work) {
		payload.response_topic = await_response(topic, id, work, broker_list);
		payload.response_topic = await_response(topic, id, work);
		(0, _logger.log)('Awaiting response on topic: ' + payload.response_topic);
		@@ -89,0 +93,0 @@ }

package.json

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

src/produce/index.js

		@@ -11,3 +11,3 @@ import fs from 'fs';

		const await_response = (topic, id, work, broker_list) => {
		const await_response = (topic, id, work) => {
		const offset = 1; // Skip the initial message which creates the topic
		@@ -23,3 +23,5 @@ const exit = true; // Cleanup when we've received our response

		const handle_producer_error = (data) => {
		const handle_producer_error = (data, callback) => {
		const error_string = `Producer logged an error: ${data.toString()}`;
		if (callback) return error(error_string);
		throw new BrokerError(`Producer logged an error: ${data.toString()}`);
		@@ -47,3 +49,3 @@ };
		producer.stdout.on('data', handle_producer_data);
		producer.stderr.on('data', handle_producer_error);
		producer.stderr.on('data', data => handle_producer_error(data, callback));
		producer.on('close', code => handle_producer_close(
		@@ -69,3 +71,3 @@ code, message_file_path, callback
		if (work) {
		payload.response_topic = await_response(topic, id, work, broker_list);
		payload.response_topic = await_response(topic, id, work);
		log(`Awaiting response on topic: ${payload.response_topic}`);
		@@ -72,0 +74,0 @@ }

New alerts