		"use strict";
		Object.defineProperty(exports, "__esModule", { value: true });
		const avro_stream_1 = require("@ovotech/avro-stream");
		const chalk_1 = require("chalk");
		const kafka_node_1 = require("kafka-node");
		@@ -20,6 +19,2 @@ const __1 = require("../../");
		const logProducer = new __1.LogProducerTransform();
		producerStream.on('finish', () => {
		console.log(chalk_1.default.green('Finished.'));
		producerStream.close();
		});
		fileReadable
		@@ -26,0 +21,0 @@ .pipe(logProducer)

dist/cli/commands/schema.d.ts

		import { CommandModule } from 'yargs';
		import { Args } from '../types';
		import { Args } from '..';
		export interface SchemaArgs extends Args {
		@@ -4,0 +4,0 @@ subject: string;

dist/cli/commands/schema.js

		@@ -8,3 +8,3 @@ "use strict";
		const util_1 = require("util");
		const config_1 = require("../config");
		const __1 = require("..");
		exports.schema = {
		@@ -14,3 +14,3 @@ command: 'schema [subject]',
		handler: async (args) => {
		const { schemaRegistry } = config_1.loadConfig(args);
		const { schemaRegistry } = __1.loadConfig(args);
		if (!schemaRegistry) {
		@@ -23,3 +23,3 @@ throw new Error('Configuration for schemaRegistry is required, add it to the config file');
		const subjects = await schema_registry_api_1.getSubjects(schemaRegistry);
		const matchingSubjects = args.subject ? subjects.filter(subject => subject.includes(args.subject)) : subjects;
		const matchingSubjects = __1.filterSearch(args.subject, subjects);
		switch (matchingSubjects.length) {
		@@ -26,0 +26,0 @@ case 0:

dist/cli/commands/topic.d.ts

		import { CommandModule } from 'yargs';
		import { Args } from '../types';
		import { Args } from '..';
		export interface TopicArgs extends Args {
		@@ -4,0 +4,0 @@ name: string;

dist/cli/commands/topic.js

		@@ -7,3 +7,3 @@ "use strict";
		const util_1 = require("util");
		const config_1 = require("../config");
		const __1 = require("..");
		exports.topic = {
		@@ -13,3 +13,3 @@ command: 'topic [name]',
		handler: async (args) => {
		const { kafkaClient } = config_1.loadConfig(args);
		const { kafkaClient } = __1.loadConfig(args);
		if (!kafkaClient) {
		@@ -24,3 +24,3 @@ throw new Error('Configuration for schemaRegistry is required, add it to the config file');
		const topics = Object.keys(metadata);
		const matchingTopics = args.name ? topics.filter(item => item.includes(args.name)) : topics;
		const matchingTopics = __1.filterSearch(args.name, topics);
		switch (matchingTopics.length) {
		@@ -27,0 +27,0 @@ case 0:

dist/cli/index.d.ts

		export { Config, Args } from './types';
		export { loadConfig } from './config';
		export { ConsumeArgs, CreateTopicArgs, ProduceArgs, SchemaArgs, TopicArgs } from './commands';
		export { filterSearch } from './helpers';

dist/cli/index.js

		@@ -5,2 +5,4 @@ "use strict";
		exports.loadConfig = config_1.loadConfig;
		var helpers_1 = require("./helpers");
		exports.filterSearch = helpers_1.filterSearch;
		//# sourceMappingURL=index.js.map

dist/index.d.ts

		export { NullWritable, ConsumerProgressTransform, LogConsumerProgressTransform, LogProducerTransform, FileWritable, FileReadable, StopOnFinishProgressTransform, } from './stream';
		export { Args, Config, ConsumeArgs, CreateTopicArgs, ProduceArgs, SchemaArgs, TopicArgs } from './cli';
		export { Args, Config, ConsumeArgs, CreateTopicArgs, ProduceArgs, SchemaArgs, TopicArgs, filterSearch } from './cli';

dist/index.js

		@@ -11,2 +11,4 @@ "use strict";
		exports.StopOnFinishProgressTransform = stream_1.StopOnFinishProgressTransform;
		var cli_1 = require("./cli");
		exports.filterSearch = cli_1.filterSearch;
		//# sourceMappingURL=index.js.map

package.json

		{
		"name": "@ovotech/kafka-avro-cli",
		"description": "A CLI for inspecting the confluent schema-registry, produce and consume avro kafka events",
		"version": "1.0.4",
		"version": "1.0.5",
		"main": "dist/index.js",
		@@ -52,3 +52,3 @@ "source": "src/index.ts",
		},
		"gitHead": "0761edbfa9260cb0a4e1c1faa331729609909fd5"
		"gitHead": "bbe8dc1298d64e79655bb9e00a828e98927c08e8"
		}

src/cli/commands/produce.ts

		@@ -27,7 +27,2 @@ import { AvroProduceRequest, AvroSerializer } from '@ovotech/avro-stream';

		producerStream.on('finish', () => {
		console.log(chalk.green('Finished.'));
		producerStream.close();
		});

		fileReadable
		@@ -34,0 +29,0 @@ .pipe(logProducer)

dist/cli/commands/produce.js.map