Skip to content

Commit

Permalink
Adding "fetch all versions" back (waldophotos#57)
Browse files Browse the repository at this point in the history
* Adding "fetch all versions" back

When the feature that allows refresh rate was released, the `_checkForAllVersion` method was removed (https://github.com/waldophotos/kafka-avro/pull/42/files#diff-f1df90835d08fdef1a9efce902948d9fL99).

This PR adds back this behavior. Thanks @manikawnth-abg

Fixes waldophotos#56

* Update changelog
  • Loading branch information
ricardohbin authored Jan 3, 2019
1 parent 8997d60 commit ccb87e9
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 1 deletion.
2 changes: 2 additions & 0 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -273,6 +273,8 @@ You can use `docker-compose up` to up all the stack before you call your integra

## Release History

- **1.1.3**, *02 January 2019*
- Fixing broken `fetchAllVersions` feature (by [ricardohbin](https://github.com/ricardohbin))
- **1.1.2**, *08 November 2018*
- Handle topics which use identical schemas (by [scottwd9](https://github.com/scottwd9))
- **1.1.1**, *23 August 2018*
Expand Down
3 changes: 2 additions & 1 deletion lib/schema-registry.js
Original file line number Diff line number Diff line change
Expand Up @@ -441,5 +441,6 @@ SchemaRegistry.prototype._fetchSchemas = function () {
.map(this._fetchLatestVersion, { concurrency: 10 })
.filter(Boolean)
.map(this._fetchSchema, { concurrency: 10 })
.map(this._registerSchemaLatest);
.map(this._registerSchemaLatest)
.then(this._checkForAllVersions);
};

0 comments on commit ccb87e9

Please sign in to comment.