kafka-avro - npm Package Compare versions

Comparing version 1.1.0 to 1.1.1

lib/schema-registry.js

		@@ -367,6 +367,6 @@ /**
		this.valueSchemas[schemaObj.topic] = schemaObj.type;
		this.schemaMeta[schemaObj.topic] = schemaObj.responseRaw;
		} else {
		this.keySchemas[schemaObj.topic] = schemaObj.type;
		}
		this.schemaMeta[schemaObj.topic] = schemaObj.responseRaw;
		return schemaObj;
		@@ -373,0 +373,0 @@ });

package.json

		{
		"name": "kafka-avro",
		"version": "1.1.0",
		"version": "1.1.1",
		"main": "./lib/kafka-avro",
		@@ -5,0 +5,0 @@ "description": "Node.js bindings for librdkafka with Avro schema serialization.",

README.md

		@@ -87,3 +87,3 @@ # kafka-avro

		var value = new Buffer('value-' +i);
		var value = {name:'John'};
		var key = 'key';
		@@ -277,2 +277,4 @@

		- 1.1.1, 23 August 2018
		- Set `schemaMeta` for key schemas also (by [eparreno](https://github.com/eparreno))
		- 1.1.0, 06 August 2018
		@@ -279,0 +281,0 @@ - Updating to node-rdkafka v2.3.4 (by [ricardohbin](https://github.com/ricardohbin))

test/spec/schema-registry.test.js

		@@ -47,14 +47,12 @@ /**
		expect(sr.valueSchemas[res.topic]).to.be.an('object');
		expect(sr.schemaMeta[res.topic]).to.be.an('object');

		expect(sr.schemaMeta[res.topic]).to.have.keys([
		'subject',
		'version',
		'id',
		'schema',
		]);

		} else {
		expect(sr.keySchemas[res.topic]).to.be.an('object');
		}
		expect(sr.schemaMeta[res.topic]).to.be.an('object');
		expect(sr.schemaMeta[res.topic]).to.have.keys([
		'subject',
		'version',
		'id',
		'schema',
		]);
		})
		@@ -61,0 +59,0 @@ .then((all) => {

New alerts