@ovotech/kafka-avro-cli
Advanced tools
Comparing version 1.2.3 to 1.2.4
@@ -37,3 +37,3 @@ "use strict"; | ||
const errorHandler = (title) => (error) => { | ||
process.stderr.write(chalk_1.default(`{red Error in ${title} ${error.message}}\n`)); | ||
process.stderr.write(chalk_1.default(`{red Error in ${title}} ${error.message}\n`)); | ||
consumerStream.close(() => { | ||
@@ -40,0 +40,0 @@ process.stderr.write('Consumer closed\n'); |
{ | ||
"name": "@ovotech/kafka-avro-cli", | ||
"description": "A CLI for inspecting the confluent schema-registry, produce and consume avro kafka events", | ||
"version": "1.2.3", | ||
"version": "1.2.4", | ||
"main": "dist/index.js", | ||
@@ -55,3 +55,3 @@ "source": "src/index.ts", | ||
}, | ||
"gitHead": "13275e577c50cfcfc4dcc464eceb1f5aec98234d" | ||
"gitHead": "c2ff32d5de573d656d6f83bea6e635e532bfeed7" | ||
} |
@@ -57,3 +57,3 @@ import { AvroDeserializer } from '@ovotech/avro-stream'; | ||
const errorHandler = (title: string) => (error: Error) => { | ||
process.stderr.write(chalk(`{red Error in ${title} ${error.message}}\n`)); | ||
process.stderr.write(chalk(`{red Error in ${title}} ${error.message}\n`)); | ||
consumerStream.close(() => { | ||
@@ -60,0 +60,0 @@ process.stderr.write('Consumer closed\n'); |
Sorry, the diff of this file is not supported yet