makeomatic/mservice

View on GitHub
packages/plugin-kafka/CHANGELOG.md

Summary

Maintainability
Test Coverage


## [6.0.1](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@6.0.0...@microfleet/plugin-kafka@6.0.1) (2024-08-02)


### Bug Fixes

* **hapi:** error code pass-through ([66ed3d0](https://github.com/microfleet/core/commit/66ed3d04cc6cf34d3169a982e90405e28790756b))

## [6.0.1](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@6.0.0...@microfleet/plugin-kafka@6.0.1) (2024-08-02)


### Bug Fixes

* **hapi:** error code pass-through ([66ed3d0](https://github.com/microfleet/core/commit/66ed3d04cc6cf34d3169a982e90405e28790756b))

# [6.0.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@5.1.4...@microfleet/plugin-kafka@6.0.0) (2024-08-01)


### Bug Fixes

* **deps:** update dependency sonic-boom to v3.8.1 ([101d9b1](https://github.com/microfleet/core/commit/101d9b1e70c464051bf162ac2f49f7cd709f7915))


### Features

* remove opentracing, cassandra, expand error msg for hapi ([#721](https://github.com/microfleet/core/issues/721)) ([b9def89](https://github.com/microfleet/core/commit/b9def89f0e344f2c6909b2f2f1db9c7f72cca8f9))


### BREAKING CHANGES

* removed opentracing & cassandra plugins. They are not maintained and are a perf hit

* feat: support error code in hapi respones as extra data
* feat: remove opentracing and cassandra
* fix: remove plugin from the list

# [6.0.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@5.1.4...@microfleet/plugin-kafka@6.0.0) (2024-08-01)


### Bug Fixes

* **deps:** update dependency sonic-boom to v3.8.1 ([101d9b1](https://github.com/microfleet/core/commit/101d9b1e70c464051bf162ac2f49f7cd709f7915))


### Features

* remove opentracing, cassandra, expand error msg for hapi ([#721](https://github.com/microfleet/core/issues/721)) ([b9def89](https://github.com/microfleet/core/commit/b9def89f0e344f2c6909b2f2f1db9c7f72cca8f9))


### BREAKING CHANGES

* removed opentracing & cassandra plugins. They are not maintained and are a perf hit

* feat: support error code in hapi respones as extra data
* feat: remove opentracing and cassandra
* fix: remove plugin from the list

## [5.1.4](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@5.1.3...@microfleet/plugin-kafka@5.1.4) (2024-07-03)


### Bug Fixes

* logger schema ([#644](https://github.com/microfleet/core/issues/644)) ([3af5be5](https://github.com/microfleet/core/commit/3af5be5a96294cf0a93df4791d4071861bf80a1a))

## [5.1.4](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@5.1.3...@microfleet/plugin-kafka@5.1.4) (2024-07-03)


### Bug Fixes

* logger schema ([#644](https://github.com/microfleet/core/issues/644)) ([3af5be5](https://github.com/microfleet/core/commit/3af5be5a96294cf0a93df4791d4071861bf80a1a))

## [5.1.3](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@5.1.2...@microfleet/plugin-kafka@5.1.3) (2024-02-12)


### Bug Fixes

* **plugin-redis-core:** file extension handling ([#706](https://github.com/microfleet/core/issues/706)) ([b3761ae](https://github.com/microfleet/core/commit/b3761ae8b1a376eaecb24c7eac499904fabf7e10))

## [5.1.3](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@5.1.2...@microfleet/plugin-kafka@5.1.3) (2024-02-12)


### Bug Fixes

* **plugin-redis-core:** file extension handling ([#706](https://github.com/microfleet/core/issues/706)) ([b3761ae](https://github.com/microfleet/core/commit/b3761ae8b1a376eaecb24c7eac499904fabf7e10))

## [5.1.2](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@5.1.1...@microfleet/plugin-kafka@5.1.2) (2024-02-11)


### Bug Fixes

* **plugin-redis-core:** perform index file if migration is a directory ([#705](https://github.com/microfleet/core/issues/705)) ([848bb8e](https://github.com/microfleet/core/commit/848bb8e28b1af1274ca9d2b0e55c6255e6a13a88))

## [5.1.2](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@5.1.1...@microfleet/plugin-kafka@5.1.2) (2024-02-11)


### Bug Fixes

* **plugin-redis-core:** perform index file if migration is a directory ([#705](https://github.com/microfleet/core/issues/705)) ([848bb8e](https://github.com/microfleet/core/commit/848bb8e28b1af1274ca9d2b0e55c6255e6a13a88))

## [5.1.1](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@5.1.0...@microfleet/plugin-kafka@5.1.1) (2024-01-26)


### Bug Fixes

* **plugin-logger:** pass error enumerable fields as event extras ([#698](https://github.com/microfleet/core/issues/698)) ([d755df3](https://github.com/microfleet/core/commit/d755df31c1937440ffb4e832d792a30bd1e93212))

## [5.1.1](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@5.1.0...@microfleet/plugin-kafka@5.1.1) (2024-01-26)


### Bug Fixes

* **plugin-logger:** pass error enumerable fields as event extras ([#698](https://github.com/microfleet/core/issues/698)) ([d755df3](https://github.com/microfleet/core/commit/d755df31c1937440ffb4e832d792a30bd1e93212))

# [5.1.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@5.0.5...@microfleet/plugin-kafka@5.1.0) (2024-01-25)


### Features

* **plugin-logger:** sentry fingerprinting ([#697](https://github.com/microfleet/core/issues/697)) ([849c599](https://github.com/microfleet/core/commit/849c599730f0561f9bdd01dbec3f16deeb08eb51))

# [5.1.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@5.0.5...@microfleet/plugin-kafka@5.1.0) (2024-01-25)


### Features

* **plugin-logger:** sentry fingerprinting ([#697](https://github.com/microfleet/core/issues/697)) ([849c599](https://github.com/microfleet/core/commit/849c599730f0561f9bdd01dbec3f16deeb08eb51))

## [5.0.5](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@5.0.4...@microfleet/plugin-kafka@5.0.5) (2024-01-17)


### Bug Fixes

* don't use logger in the mfleet ([61fdffc](https://github.com/microfleet/core/commit/61fdffc15f91941d13340035f58a75119bc80670))

## [5.0.5](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@5.0.4...@microfleet/plugin-kafka@5.0.5) (2024-01-17)


### Bug Fixes

* don't use logger in the mfleet ([61fdffc](https://github.com/microfleet/core/commit/61fdffc15f91941d13340035f58a75119bc80670))

## [5.0.4](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@5.0.3...@microfleet/plugin-kafka@5.0.4) (2024-01-05)


### Bug Fixes

* auto-starting an instance in ESM ([157d2a5](https://github.com/microfleet/core/commit/157d2a5cb60f881467a62c3e6aab34c1018b333d))

## [5.0.4](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@5.0.3...@microfleet/plugin-kafka@5.0.4) (2024-01-05)


### Bug Fixes

* auto-starting an instance in ESM ([157d2a5](https://github.com/microfleet/core/commit/157d2a5cb60f881467a62c3e6aab34c1018b333d))

## [5.0.3](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@5.0.2...@microfleet/plugin-kafka@5.0.3) (2024-01-05)


### Bug Fixes

* ensure full paths are resolved for generic actions in ESM mode ([a02d85f](https://github.com/microfleet/core/commit/a02d85fe88b1874d8a02c35f8c2fa76ba400cee5))

## [5.0.3](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@5.0.2...@microfleet/plugin-kafka@5.0.3) (2024-01-05)


### Bug Fixes

* ensure full paths are resolved for generic actions in ESM mode ([a02d85f](https://github.com/microfleet/core/commit/a02d85fe88b1874d8a02c35f8c2fa76ba400cee5))

## [5.0.2](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@5.0.1...@microfleet/plugin-kafka@5.0.2) (2024-01-04)


### Bug Fixes

* dynamic import calls, swc -> esbuild ([7e6d1a2](https://github.com/microfleet/core/commit/7e6d1a29c92979626cab8ac96c9c55c02c19ab40))

## [5.0.2](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@5.0.1...@microfleet/plugin-kafka@5.0.2) (2024-01-04)


### Bug Fixes

* dynamic import calls, swc -> esbuild ([7e6d1a2](https://github.com/microfleet/core/commit/7e6d1a29c92979626cab8ac96c9c55c02c19ab40))

## [5.0.1](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@5.0.0...@microfleet/plugin-kafka@5.0.1) (2024-01-03)


### Bug Fixes

* wrong peer dep ([aeea4a0](https://github.com/microfleet/core/commit/aeea4a080492b24ca0ed544e3f791e3df9149209))

## [5.0.1](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@5.0.0...@microfleet/plugin-kafka@5.0.1) (2024-01-03)


### Bug Fixes

* wrong peer dep ([aeea4a0](https://github.com/microfleet/core/commit/aeea4a080492b24ca0ed544e3f791e3df9149209))

# [5.0.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@4.3.0...@microfleet/plugin-kafka@5.0.0) (2024-01-03)


### Features

* async plugin registration ([#694](https://github.com/microfleet/core/issues/694)) ([3b7969a](https://github.com/microfleet/core/commit/3b7969ae755862832889ae04fe4ef80e483b561d))


### BREAKING CHANGES

* requires oen to call await microfleet.register() before any of the plugins are instantiated. This allows one to have async jobs as part of the attachment routine. Updates @microfleet/validation to version 13, which moves from require() to async import() of files as part of this change. This raises min node.js version to 20.10 (it will still work on lower versions, but >= 20.10 allows for much better performance, as well as way fewer ESM issues). This will be a non-lts version aimed at polishing async plugins and tightening public interface

# [5.0.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@4.3.0...@microfleet/plugin-kafka@5.0.0) (2024-01-03)


### Features

* async plugin registration ([#694](https://github.com/microfleet/core/issues/694)) ([3b7969a](https://github.com/microfleet/core/commit/3b7969ae755862832889ae04fe4ef80e483b561d))


### BREAKING CHANGES

* requires oen to call await microfleet.register() before any of the plugins are instantiated. This allows one to have async jobs as part of the attachment routine. Updates @microfleet/validation to version 13, which moves from require() to async import() of files as part of this change. This raises min node.js version to 20.10 (it will still work on lower versions, but >= 20.10 allows for much better performance, as well as way fewer ESM issues). This will be a non-lts version aimed at polishing async plugins and tightening public interface

# [4.3.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@4.2.14...@microfleet/plugin-kafka@4.3.0) (2024-01-02)


### Features

* use dynamic import in readRoutes ([#686](https://github.com/microfleet/core/issues/686)) ([e62ce12](https://github.com/microfleet/core/commit/e62ce12d2b8449813977f345164fcc41b61aa748))

# [4.3.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@4.2.14...@microfleet/plugin-kafka@4.3.0) (2024-01-02)


### Features

* use dynamic import in readRoutes ([#686](https://github.com/microfleet/core/issues/686)) ([e62ce12](https://github.com/microfleet/core/commit/e62ce12d2b8449813977f345164fcc41b61aa748))

## [4.2.14](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@4.2.13...@microfleet/plugin-kafka@4.2.14) (2023-12-20)


### Bug Fixes

* @microfleet/validation v11.2.1 ([#683](https://github.com/microfleet/core/issues/683)) ([09339f0](https://github.com/microfleet/core/commit/09339f07ee876798076c56d0fc25c5b5435247c1))

## [4.2.14](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@4.2.13...@microfleet/plugin-kafka@4.2.14) (2023-12-20)


### Bug Fixes

* @microfleet/validation v11.2.1 ([#683](https://github.com/microfleet/core/issues/683)) ([09339f0](https://github.com/microfleet/core/commit/09339f07ee876798076c56d0fc25c5b5435247c1))

## [4.2.13](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@4.2.12...@microfleet/plugin-kafka@4.2.13) (2023-12-19)


### Bug Fixes

* update deps ([e6e043b](https://github.com/microfleet/core/commit/e6e043b1c4c59c4e39bcb6ed81f3e57c1434e19a))

## [4.2.13](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@4.2.12...@microfleet/plugin-kafka@4.2.13) (2023-12-19)


### Bug Fixes

* update deps ([e6e043b](https://github.com/microfleet/core/commit/e6e043b1c4c59c4e39bcb6ed81f3e57c1434e19a))

## [4.2.12](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@4.2.11...@microfleet/plugin-kafka@4.2.12) (2023-11-21)


### Bug Fixes

* kafka update ([a720d81](https://github.com/microfleet/core/commit/a720d8179aecb4a161b72eefbf2579252b56fcc0))

## [4.2.12](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@4.2.11...@microfleet/plugin-kafka@4.2.12) (2023-11-21)


### Bug Fixes

* kafka update ([a720d81](https://github.com/microfleet/core/commit/a720d8179aecb4a161b72eefbf2579252b56fcc0))

## [4.2.11](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@4.2.10...@microfleet/plugin-kafka@4.2.11) (2023-11-15)


### Bug Fixes

* upgrade dependencies ([3462882](https://github.com/microfleet/core/commit/3462882b1b6017f8e5072468f38e7fbd7903d044))
* upgrade deps, more granular log level control in logger plugin ([fa59e6f](https://github.com/microfleet/core/commit/fa59e6f6a8959b81bd38f5b2bdb12d335b6e5844))

## [4.2.11](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@4.2.10...@microfleet/plugin-kafka@4.2.11) (2023-11-15)


### Bug Fixes

* upgrade dependencies ([3462882](https://github.com/microfleet/core/commit/3462882b1b6017f8e5072468f38e7fbd7903d044))
* upgrade deps, more granular log level control in logger plugin ([fa59e6f](https://github.com/microfleet/core/commit/fa59e6f6a8959b81bd38f5b2bdb12d335b6e5844))

## [4.2.10](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@4.2.9...@microfleet/plugin-kafka@4.2.10) (2023-10-25)


### Bug Fixes

* upgrade deps, extras for sentry ([#674](https://github.com/microfleet/core/issues/674)) ([209eb8d](https://github.com/microfleet/core/commit/209eb8dd8b2ba086ebda004ead7b25739bade72f))

## [4.2.10](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@4.2.9...@microfleet/plugin-kafka@4.2.10) (2023-10-25)


### Bug Fixes

* upgrade deps, extras for sentry ([#674](https://github.com/microfleet/core/issues/674)) ([209eb8d](https://github.com/microfleet/core/commit/209eb8dd8b2ba086ebda004ead7b25739bade72f))

## [4.2.9](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@4.2.8...@microfleet/plugin-kafka@4.2.9) (2023-09-27)


### Bug Fixes

* update deps, router .d.ts ([#664](https://github.com/microfleet/core/issues/664)) ([b9df1ac](https://github.com/microfleet/core/commit/b9df1ac56760499418018c723a2f6f8c3fbbbda9))

## [4.2.9](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@4.2.8...@microfleet/plugin-kafka@4.2.9) (2023-09-27)


### Bug Fixes

* update deps, router .d.ts ([#664](https://github.com/microfleet/core/issues/664)) ([b9df1ac](https://github.com/microfleet/core/commit/b9df1ac56760499418018c723a2f6f8c3fbbbda9))

## [4.2.8](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@4.2.7...@microfleet/plugin-kafka@4.2.8) (2023-06-20)


### Bug Fixes

* update deps, ensure fastify-plugin is not required ([08f0239](https://github.com/microfleet/core/commit/08f023940232068022aeaecbbb88b619204921d8))

## [4.2.8](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@4.2.7...@microfleet/plugin-kafka@4.2.8) (2023-06-20)


### Bug Fixes

* update deps, ensure fastify-plugin is not required ([08f0239](https://github.com/microfleet/core/commit/08f023940232068022aeaecbbb88b619204921d8))

## [4.2.7](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@4.2.6...@microfleet/plugin-kafka@4.2.7) (2023-05-30)


### Bug Fixes

* cleanup sigterm listeners on close ([cd19c53](https://github.com/microfleet/core/commit/cd19c53f1e52fb1a5c5ca1ec82f2bbd055a529ee))

## [4.2.7](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@4.2.6...@microfleet/plugin-kafka@4.2.7) (2023-05-30)


### Bug Fixes

* cleanup sigterm listeners on close ([cd19c53](https://github.com/microfleet/core/commit/cd19c53f1e52fb1a5c5ca1ec82f2bbd055a529ee))

## [4.2.6](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@4.2.5...@microfleet/plugin-kafka@4.2.6) (2023-05-17)


### Bug Fixes

* set npm version during release ([24edf47](https://github.com/microfleet/core/commit/24edf478bab0547560103707267226e7105ac363))
* update compatibility for mfleet bin ([01285ed](https://github.com/microfleet/core/commit/01285ed96ce21b68e1eadbddda70c8587c288fd0))

## [4.2.6](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@4.2.5...@microfleet/plugin-kafka@4.2.6) (2023-05-17)


### Bug Fixes

* set npm version during release ([24edf47](https://github.com/microfleet/core/commit/24edf478bab0547560103707267226e7105ac363))
* update compatibility for mfleet bin ([01285ed](https://github.com/microfleet/core/commit/01285ed96ce21b68e1eadbddda70c8587c288fd0))

## [4.2.5](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@4.2.5...@microfleet/plugin-kafka@4.2.5) (2023-05-17)


### Bug Fixes

* set npm version during release ([24edf47](https://github.com/microfleet/core/commit/24edf478bab0547560103707267226e7105ac363))

## [4.2.5](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@4.2.5...@microfleet/plugin-kafka@4.2.5) (2023-05-17)


### Bug Fixes

* set npm version during release ([24edf47](https://github.com/microfleet/core/commit/24edf478bab0547560103707267226e7105ac363))

## [4.2.5](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@4.2.3...@microfleet/plugin-kafka@4.2.5) (2023-05-17)


### Bug Fixes

* no double increment ([b2e654c](https://github.com/microfleet/core/commit/b2e654c8d3fe000a26e651a4313eed073b3afaf6))

## [4.2.5](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@4.2.3...@microfleet/plugin-kafka@4.2.5) (2023-05-17)


### Bug Fixes

* no double increment ([b2e654c](https://github.com/microfleet/core/commit/b2e654c8d3fe000a26e651a4313eed073b3afaf6))

## [4.2.4](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@4.2.1...@microfleet/plugin-kafka@4.2.4) (2023-05-17)


### Bug Fixes

* adjust mfleet loader ([43a2dbe](https://github.com/microfleet/core/commit/43a2dbe0ed1a2a9c6e0263fbae91f74637c6ef98))

## [4.2.3](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@4.2.1...@microfleet/plugin-kafka@4.2.3) (2023-05-17)


### Bug Fixes

* adjust mfleet loader ([43a2dbe](https://github.com/microfleet/core/commit/43a2dbe0ed1a2a9c6e0263fbae91f74637c6ef98))

## [4.2.2](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@4.1.0...@microfleet/plugin-kafka@4.2.2) (2023-05-17)


### Bug Fixes

* update dependencies ([#645](https://github.com/microfleet/core/issues/645)) ([9e2a778](https://github.com/microfleet/core/commit/9e2a7785bc818dd6f1a920c65c671400a42842cd))
* update dlock wrapper ([7c16a15](https://github.com/microfleet/core/commit/7c16a152d55f9d3a41838944f9e272475cca0977))

## [4.2.1](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@4.1.0...@microfleet/plugin-kafka@4.2.1) (2023-05-17)


### Bug Fixes

* update dependencies ([#645](https://github.com/microfleet/core/issues/645)) ([9e2a778](https://github.com/microfleet/core/commit/9e2a7785bc818dd6f1a920c65c671400a42842cd))
* update dlock wrapper ([7c16a15](https://github.com/microfleet/core/commit/7c16a152d55f9d3a41838944f9e272475cca0977))

# [4.2.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@3.0.0...@microfleet/plugin-kafka@4.2.0) (2023-01-26)


### Features

* common action overrides ([516cebb](https://github.com/microfleet/core/commit/516cebb5f24b6eb050fd524c83e4468dd6f8d82d))

# [4.1.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@3.0.0...@microfleet/plugin-kafka@4.1.0) (2023-01-26)


### Features

* common action overrides ([516cebb](https://github.com/microfleet/core/commit/516cebb5f24b6eb050fd524c83e4468dd6f8d82d))

# [4.0.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.32.0...@microfleet/plugin-kafka@4.0.0) (2023-01-23)


### Features

* init custom plugin with abs path from core ([#641](https://github.com/microfleet/core/issues/641)) ([b9e0a30](https://github.com/microfleet/core/commit/b9e0a30a8f262d50aa325185aca9b49ae4da6eb8))


### BREAKING CHANGES

* several plugins had major version of node updates in its req, hence boosting this

* chore: lockfile
* feat: init custom plugin with abs path from core
* chore: update test env

# [3.0.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.32.0...@microfleet/plugin-kafka@3.0.0) (2023-01-23)


### Features

* init custom plugin with abs path from core ([#641](https://github.com/microfleet/core/issues/641)) ([b9e0a30](https://github.com/microfleet/core/commit/b9e0a30a8f262d50aa325185aca9b49ae4da6eb8))


### BREAKING CHANGES

* several plugins had major version of node updates in its req, hence boosting this

* chore: lockfile
* feat: init custom plugin with abs path from core
* chore: update test env

# [2.33.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.30.0...@microfleet/plugin-kafka@2.33.0) (2022-11-01)


### Features

* upgrade dependencies, no breaking changes ([#638](https://github.com/microfleet/core/issues/638)) ([2d4de4d](https://github.com/microfleet/core/commit/2d4de4d080be30dcf01ba3f05599ec15618dde90))

# [2.32.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.30.0...@microfleet/plugin-kafka@2.32.0) (2022-11-01)


### Features

* upgrade dependencies, no breaking changes ([#638](https://github.com/microfleet/core/issues/638)) ([2d4de4d](https://github.com/microfleet/core/commit/2d4de4d080be30dcf01ba3f05599ec15618dde90))

# [2.31.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.29.1...@microfleet/plugin-kafka@2.31.0) (2022-10-27)


### Features

* **plugin-signed-request:** fastify plugin ([#637](https://github.com/microfleet/core/issues/637)) ([ee3d4dd](https://github.com/microfleet/core/commit/ee3d4dd1adc3025dbd6d831aeeb0dce9f44117f0))

# [2.30.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.29.1...@microfleet/plugin-kafka@2.30.0) (2022-10-27)


### Features

* **plugin-signed-request:** fastify plugin ([#637](https://github.com/microfleet/core/issues/637)) ([ee3d4dd](https://github.com/microfleet/core/commit/ee3d4dd1adc3025dbd6d831aeeb0dce9f44117f0))

## [2.29.2](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.28.0...@microfleet/plugin-kafka@2.29.2) (2022-09-02)


### Bug Fixes

* improve sentry logger ([#636](https://github.com/microfleet/core/issues/636)) ([93e75da](https://github.com/microfleet/core/commit/93e75da4f3a34606940c2673460c4719dcef2012))

## [2.29.1](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.28.0...@microfleet/plugin-kafka@2.29.1) (2022-09-02)


### Bug Fixes

* improve sentry logger ([#636](https://github.com/microfleet/core/issues/636)) ([93e75da](https://github.com/microfleet/core/commit/93e75da4f3a34606940c2673460c4719dcef2012))

# [2.29.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.27.1...@microfleet/plugin-kafka@2.29.0) (2022-08-27)


### Bug Fixes

* upgrade deps ([5ed4b64](https://github.com/microfleet/core/commit/5ed4b64f5bac473ebd267e9dd1abb1077dd7738f))


### Features

* improve sentry logger ([#633](https://github.com/microfleet/core/issues/633)) ([d50fba9](https://github.com/microfleet/core/commit/d50fba93835a0fceb9ada8f52075946e5bf2bed7)), closes [#635](https://github.com/microfleet/core/issues/635)

# [2.28.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.27.1...@microfleet/plugin-kafka@2.28.0) (2022-08-27)


### Bug Fixes

* upgrade deps ([5ed4b64](https://github.com/microfleet/core/commit/5ed4b64f5bac473ebd267e9dd1abb1077dd7738f))


### Features

* improve sentry logger ([#633](https://github.com/microfleet/core/issues/633)) ([d50fba9](https://github.com/microfleet/core/commit/d50fba93835a0fceb9ada8f52075946e5bf2bed7)), closes [#635](https://github.com/microfleet/core/issues/635)

## [2.27.2](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.26.0...@microfleet/plugin-kafka@2.27.2) (2022-07-15)


### Bug Fixes

* remove timer based ack defaults ([0babab1](https://github.com/microfleet/core/commit/0babab1a98bedc98c39991f0d07fbd61c5c50409))

## [2.27.1](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.26.0...@microfleet/plugin-kafka@2.27.1) (2022-07-15)


### Bug Fixes

* remove timer based ack defaults ([0babab1](https://github.com/microfleet/core/commit/0babab1a98bedc98c39991f0d07fbd61c5c50409))

# [2.27.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.24.0...@microfleet/plugin-kafka@2.27.0) (2022-07-14)


### Bug Fixes

* increase test timeout for slow machines on CI ([61cc970](https://github.com/microfleet/core/commit/61cc970b9c636b4b3a076a3715dc9ec20d6f838d))
* undici vs node-fetch ([bd38a18](https://github.com/microfleet/core/commit/bd38a18f005d0c29a2b73b9e181948cc30ec0543))


### Features

* pino 8 and other deps ([15dfb1b](https://github.com/microfleet/core/commit/15dfb1b3834584ec2c5c6bb20cdd5911055e6dda))

# [2.26.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.24.0...@microfleet/plugin-kafka@2.26.0) (2022-07-14)


### Bug Fixes

* increase test timeout for slow machines on CI ([61cc970](https://github.com/microfleet/core/commit/61cc970b9c636b4b3a076a3715dc9ec20d6f838d))
* undici vs node-fetch ([bd38a18](https://github.com/microfleet/core/commit/bd38a18f005d0c29a2b73b9e181948cc30ec0543))


### Features

* pino 8 and other deps ([15dfb1b](https://github.com/microfleet/core/commit/15dfb1b3834584ec2c5c6bb20cdd5911055e6dda))

# [2.25.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.22.0...@microfleet/plugin-kafka@2.25.0) (2022-07-11)


### Features

* plugin signed request ([#619](https://github.com/microfleet/core/issues/619)) ([fd51e06](https://github.com/microfleet/core/commit/fd51e062b43743c968affc8b5a2aa4b37380c2cc))# [2.24.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.22.0...@microfleet/plugin-kafka@2.24.0) (2022-07-11)


### Features

* plugin signed request ([#619](https://github.com/microfleet/core/issues/619)) ([fd51e06](https://github.com/microfleet/core/commit/fd51e062b43743c968affc8b5a2aa4b37380c2cc))# [2.23.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.20.0...@microfleet/plugin-kafka@2.23.0) (2022-06-20)


### Features

* casl RBAC plugin ([#617](https://github.com/microfleet/core/issues/617)) ([5e8a2bd](https://github.com/microfleet/core/commit/5e8a2bd703050c06c85f1846af6362e610c7e38f))# [2.22.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.20.0...@microfleet/plugin-kafka@2.22.0) (2022-06-20)


### Features

* casl RBAC plugin ([#617](https://github.com/microfleet/core/issues/617)) ([5e8a2bd](https://github.com/microfleet/core/commit/5e8a2bd703050c06c85f1846af6362e610c7e38f))# [2.21.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.19.1...@microfleet/plugin-kafka@2.21.0) (2022-03-30)


### Features

* added ability to disable some route ([#607](https://github.com/microfleet/core/issues/607)) ([afbebd2](https://github.com/microfleet/core/commit/afbebd25ba52b8b70f1f1640554a86dca509a1cf))# [2.20.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.19.1...@microfleet/plugin-kafka@2.20.0) (2022-03-30)


### Features

* added ability to disable some route ([#607](https://github.com/microfleet/core/issues/607)) ([afbebd2](https://github.com/microfleet/core/commit/afbebd25ba52b8b70f1f1640554a86dca509a1cf))## [2.19.2](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.18.0...@microfleet/plugin-kafka@2.19.2) (2022-03-25)


### Bug Fixes

* better healthcheck message ([7eed724](https://github.com/microfleet/core/commit/7eed724122c7e40890ee26327e992652c892134f))## [2.19.1](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.18.0...@microfleet/plugin-kafka@2.19.1) (2022-03-25)


### Bug Fixes

* better healthcheck message ([7eed724](https://github.com/microfleet/core/commit/7eed724122c7e40890ee26327e992652c892134f))# [2.19.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.16.0...@microfleet/plugin-kafka@2.19.0) (2022-03-24)


### Features

* router re-wiring of requests, independent actions ([fb0bea2](https://github.com/microfleet/core/commit/fb0bea24ce83bfaa6ae51e418d30161e8be7d6a0))# [2.18.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.16.0...@microfleet/plugin-kafka@2.18.0) (2022-03-24)


### Features

* router re-wiring of requests, independent actions ([fb0bea2](https://github.com/microfleet/core/commit/fb0bea24ce83bfaa6ae51e418d30161e8be7d6a0))# [2.17.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.15.3...@microfleet/plugin-kafka@2.17.0) (2022-03-24)


### Features

* **router:** reconfigure action through enabled param ([44be4ae](https://github.com/microfleet/core/commit/44be4ae4d3ccda8744f3f7dcbe098553f89386d5))# [2.16.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.15.3...@microfleet/plugin-kafka@2.16.0) (2022-03-24)


### Features

* **router:** reconfigure action through enabled param ([44be4ae](https://github.com/microfleet/core/commit/44be4ae4d3ccda8744f3f7dcbe098553f89386d5))## [2.15.4](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.15.1...@microfleet/plugin-kafka@2.15.4) (2022-03-23)


### Bug Fixes

* remove deprecated event-to-promise lib ([3489d98](https://github.com/microfleet/core/commit/3489d9866f8273c86cdff6722e582df747572c8d))## [2.15.3](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.15.1...@microfleet/plugin-kafka@2.15.3) (2022-03-23)


### Bug Fixes

* remove deprecated event-to-promise lib ([3489d98](https://github.com/microfleet/core/commit/3489d9866f8273c86cdff6722e582df747572c8d))## [2.15.2](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.14.0...@microfleet/plugin-kafka@2.15.2) (2022-03-23)


### Bug Fixes

* dependencies, updated transport-amqp ([4ca88c7](https://github.com/microfleet/core/commit/4ca88c7f8b84390f85b64dea3a665558f48d8d3b))## [2.15.1](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.14.0...@microfleet/plugin-kafka@2.15.1) (2022-03-23)


### Bug Fixes

* dependencies, updated transport-amqp ([4ca88c7](https://github.com/microfleet/core/commit/4ca88c7f8b84390f85b64dea3a665558f48d8d3b))# [2.15.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.13.1...@microfleet/plugin-kafka@2.15.0) (2022-03-16)


### Features

* microleet/transport-amqp@17 ([#604](https://github.com/microfleet/core/issues/604)) ([c06a64d](https://github.com/microfleet/core/commit/c06a64d10771f71808f01b954472d1ad86786965))# [2.14.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.13.1...@microfleet/plugin-kafka@2.14.0) (2022-03-16)


### Features

* microleet/transport-amqp@17 ([#604](https://github.com/microfleet/core/issues/604)) ([c06a64d](https://github.com/microfleet/core/commit/c06a64d10771f71808f01b954472d1ad86786965))undefined

## [2.13.2](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.12.0...@microfleet/plugin-kafka@2.13.2) (2022-02-28)


### Bug Fixes

* peer x-deps ([df1619d](https://github.com/microfleet/core/commit/df1619d84d9f9ae404aae2d75e2c0047576176de))undefined

## [2.13.1](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.12.0...@microfleet/plugin-kafka@2.13.1) (2022-02-28)


### Bug Fixes

* peer x-deps ([df1619d](https://github.com/microfleet/core/commit/df1619d84d9f9ae404aae2d75e2c0047576176de))undefined

# [2.13.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.11.13...@microfleet/plugin-kafka@2.13.0) (2022-02-27)


### Features

* support v16 of @microfleet/transport-amqp ([71579d7](https://github.com/microfleet/core/commit/71579d77cf179607477d1b803cf569c453b354b3))undefined

# [2.12.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.11.13...@microfleet/plugin-kafka@2.12.0) (2022-02-27)


### Features

* support v16 of @microfleet/transport-amqp ([71579d7](https://github.com/microfleet/core/commit/71579d77cf179607477d1b803cf569c453b354b3))## [2.11.14](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.11.11...@microfleet/plugin-kafka@2.11.14) (2022-02-25)


### Bug Fixes

* **amqp:** dont crash on missing headers ([0ca3783](https://github.com/microfleet/core/commit/0ca3783bbde7980c34462da58c7c62fbcc6142f8))

## [2.11.13](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.11.11...@microfleet/plugin-kafka@2.11.13) (2022-02-25)


### Bug Fixes

* **amqp:** dont crash on missing headers ([0ca3783](https://github.com/microfleet/core/commit/0ca3783bbde7980c34462da58c7c62fbcc6142f8))

## [2.11.12](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.11.9...@microfleet/plugin-kafka@2.11.12) (2022-02-24)


### Bug Fixes

* remove amqp type stubs ([60c9c7a](https://github.com/microfleet/core/commit/60c9c7a0e85ef68832aa7150469c10f3a8828a04))

## [2.11.11](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.11.9...@microfleet/plugin-kafka@2.11.11) (2022-02-24)


### Bug Fixes

* remove amqp type stubs ([60c9c7a](https://github.com/microfleet/core/commit/60c9c7a0e85ef68832aa7150469c10f3a8828a04))

## [2.11.10](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.11.7...@microfleet/plugin-kafka@2.11.10) (2022-02-24)


### Bug Fixes

* update deps ([97f391b](https://github.com/microfleet/core/commit/97f391b4d7c24410f532873ece685c072f3453d9))
* upgrade amqp ([8d735db](https://github.com/microfleet/core/commit/8d735db31e1029fd7f6cb23633686435bb72f4d0))
* upgrade transport-amqp ([382a1bf](https://github.com/microfleet/core/commit/382a1bf57626d375c5c8d3a959bba8f20bb27801))

## [2.11.9](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.11.7...@microfleet/plugin-kafka@2.11.9) (2022-02-24)


### Bug Fixes

* update deps ([97f391b](https://github.com/microfleet/core/commit/97f391b4d7c24410f532873ece685c072f3453d9))
* upgrade amqp ([8d735db](https://github.com/microfleet/core/commit/8d735db31e1029fd7f6cb23633686435bb72f4d0))
* upgrade transport-amqp ([382a1bf](https://github.com/microfleet/core/commit/382a1bf57626d375c5c8d3a959bba8f20bb27801))

## [2.11.8](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.11.5...@microfleet/plugin-kafka@2.11.8) (2022-02-22)


### Bug Fixes

* **router:** add `enabled` into ajv schema ([b2b4a28](https://github.com/microfleet/core/commit/b2b4a2821fc1cc70b941e8acb15b46b3ff82eba8))

## [2.11.7](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.11.5...@microfleet/plugin-kafka@2.11.7) (2022-02-22)


### Bug Fixes

* **router:** add `enabled` into ajv schema ([b2b4a28](https://github.com/microfleet/core/commit/b2b4a2821fc1cc70b941e8acb15b46b3ff82eba8))

## [2.11.6](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.11.3...@microfleet/plugin-kafka@2.11.6) (2022-02-06)


### Bug Fixes

* sentry fn opts ([4a81984](https://github.com/microfleet/core/commit/4a81984224c4b42d4184ee6d365b7ac8ad4f704d))

## [2.11.5](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.11.3...@microfleet/plugin-kafka@2.11.5) (2022-02-06)


### Bug Fixes

* sentry fn opts ([4a81984](https://github.com/microfleet/core/commit/4a81984224c4b42d4184ee6d365b7ac8ad4f704d))

## [2.11.4](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.11.1...@microfleet/plugin-kafka@2.11.4) (2022-02-04)


### Bug Fixes

* dlock with connect/close interface ([#593](https://github.com/microfleet/core/issues/593)) ([5aa9bae](https://github.com/microfleet/core/commit/5aa9baeddff6c9737a1d36f95859e9895bf99acb))

## [2.11.3](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.11.1...@microfleet/plugin-kafka@2.11.3) (2022-02-04)


### Bug Fixes

* dlock with connect/close interface ([#593](https://github.com/microfleet/core/issues/593)) ([5aa9bae](https://github.com/microfleet/core/commit/5aa9baeddff6c9737a1d36f95859e9895bf99acb))

## [2.11.2](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.10.0...@microfleet/plugin-kafka@2.11.2) (2022-01-31)


### Bug Fixes

* remove wtfnode from deps ([035482c](https://github.com/microfleet/core/commit/035482cb461afb5399b4ed40b18fc1eab5dd0315))
* update dependencies ([4d3fcce](https://github.com/microfleet/core/commit/4d3fcce259f8a047a94dc40fc66604fae8a97050))


### Reverts

* router types exploration ([40ece1e](https://github.com/microfleet/core/commit/40ece1e8e701ac3e3f34f97016b1a94f517da515))

## [2.11.1](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.10.0...@microfleet/plugin-kafka@2.11.1) (2022-01-31)


### Bug Fixes

* remove wtfnode from deps ([035482c](https://github.com/microfleet/core/commit/035482cb461afb5399b4ed40b18fc1eab5dd0315))
* update dependencies ([4d3fcce](https://github.com/microfleet/core/commit/4d3fcce259f8a047a94dc40fc66604fae8a97050))


### Reverts

* router types exploration ([40ece1e](https://github.com/microfleet/core/commit/40ece1e8e701ac3e3f34f97016b1a94f517da515))

# [2.11.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.9.0...@microfleet/plugin-kafka@2.11.0) (2022-01-31)


### Bug Fixes

* **kafka:** kafka throws when connecting to non-existent topics ([5cdf1a8](https://github.com/microfleet/core/commit/5cdf1a8cffaca0d166f97a169209f2d579804f73))
* **kafka:** use @makeomatic/node-rdkafka ([7627d66](https://github.com/microfleet/core/commit/7627d669ad49032f3a2f4be15a12a678d7136464))
* **router:** graceful shutdown fixed ([5f49652](https://github.com/microfleet/core/commit/5f49652458eb6c622f519259ae865cac42b48961))
* **tooling:** dep versions for pnpm ([cac9f31](https://github.com/microfleet/core/commit/cac9f31a9e1e8577cb0251646410199d2b6c3eb8))


### Features

* @swc/node ([260e1bb](https://github.com/microfleet/core/commit/260e1bb049563df1b3795f1ac47699103601a87f))

# [2.10.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.9.0...@microfleet/plugin-kafka@2.10.0) (2022-01-31)


### Bug Fixes

* **kafka:** kafka throws when connecting to non-existent topics ([5cdf1a8](https://github.com/microfleet/core/commit/5cdf1a8cffaca0d166f97a169209f2d579804f73))
* **kafka:** use @makeomatic/node-rdkafka ([7627d66](https://github.com/microfleet/core/commit/7627d669ad49032f3a2f4be15a12a678d7136464))
* **router:** graceful shutdown fixed ([5f49652](https://github.com/microfleet/core/commit/5f49652458eb6c622f519259ae865cac42b48961))
* **tooling:** dep versions for pnpm ([cac9f31](https://github.com/microfleet/core/commit/cac9f31a9e1e8577cb0251646410199d2b6c3eb8))


### Features

* @swc/node ([260e1bb](https://github.com/microfleet/core/commit/260e1bb049563df1b3795f1ac47699103601a87f))

# Change Log

All notable changes to this project will be documented in this file.
See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.

# [2.9.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.8.3...@microfleet/plugin-kafka@2.9.0) (2022-01-19)


### Features

* upgrade plugin-validation and update deps ([#581](https://github.com/microfleet/core/issues/581)) ([f71edfa](https://github.com/microfleet/core/commit/f71edfa4a753a0dc2918ee7664306f79d5e5a09e))





## [2.8.3](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.8.2...@microfleet/plugin-kafka@2.8.3) (2021-12-06)

**Note:** Version bump only for package @microfleet/plugin-kafka





## [2.8.2](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.8.1...@microfleet/plugin-kafka@2.8.2) (2021-12-01)

**Note:** Version bump only for package @microfleet/plugin-kafka





## [2.8.1](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.8.0...@microfleet/plugin-kafka@2.8.1) (2021-11-23)


### Bug Fixes

* update deps ([37f0e04](https://github.com/microfleet/core/commit/37f0e047d8df3ff5d9eb0abd91a98db2bd627d71))





# [2.8.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.7.1...@microfleet/plugin-kafka@2.8.0) (2021-11-23)


### Features

* pino 7 transports, mocha & jest tests ([3f90cda](https://github.com/microfleet/core/commit/3f90cda510f2891c87087d1b7c0106150d2d7ba1))





## [2.7.1](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.7.0...@microfleet/plugin-kafka@2.7.1) (2021-08-02)


### Bug Fixes

* **plugin-kafka:** correct eof handling ([#526](https://github.com/microfleet/core/issues/526)) ([d73a9de](https://github.com/microfleet/core/commit/d73a9dee02c873a3c70dd73787e4ab1753173cbe))





# [2.7.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.6.6...@microfleet/plugin-kafka@2.7.0) (2021-07-08)


### Bug Fixes

* conflicts ([035ec0d](https://github.com/microfleet/core/commit/035ec0da4959036ba6b31c948c0d06713dafa5b8))
* missing schema publish in redis sentinel plugin ([be06397](https://github.com/microfleet/core/commit/be0639786ac3d7d796d7b045d149038f544ea82b))
* update dlock plugin ([2f506ac](https://github.com/microfleet/core/commit/2f506ac0d472db27cd6637c5138b1b2e38ae91ce))
* **debug:** skip kafka test ([9e0998d](https://github.com/microfleet/core/commit/9e0998d8ab03827f1404ff410469c94dcc253327))
* **debug:** skip kafka test ([ccabf1a](https://github.com/microfleet/core/commit/ccabf1a6b0156851b6b830cf1f83e81556548562))
* **tests:** enable kafka tests ([be9f6b4](https://github.com/microfleet/core/commit/be9f6b4d5574e9a4fd54fea2535df1d2ab23a2bc))
* **tests:** upgrade transport-amqp ([012e4ee](https://github.com/microfleet/core/commit/012e4eecad069782c2c55dde92f88df503669a1e))
* kafka typings ([a2a4a7e](https://github.com/microfleet/core/commit/a2a4a7e7c0c2e57639e9dd59b6736d056f7528f6))
* linter error ([0de549b](https://github.com/microfleet/core/commit/0de549b44023106ae9a29d9afb45680f5050f84d))
* ts-ignore for pino symbol ([8847eae](https://github.com/microfleet/core/commit/8847eae445f984b58ab95d607a3c62755579697d))
* type updates ([af430df](https://github.com/microfleet/core/commit/af430dff91213d280e5aa3f0fd5592695553e9c2))


### Features

* elasticsearch, redis plugins ([79bc4c3](https://github.com/microfleet/core/commit/79bc4c384abb8cf9902697cc3931130e00397a69))
* improve perf based on benchmarks ([2ad3aac](https://github.com/microfleet/core/commit/2ad3aac102721d47184263b008ff1d92fa54d754))
* kafka upgrades, remove unused plugins ([12f8018](https://github.com/microfleet/core/commit/12f8018ceade8d95759da09eac8bab2ab9a9aade))
* merge router ([c05d1d9](https://github.com/microfleet/core/commit/c05d1d97c3ab0e2d6e55729b4c5fca4bf346751b))
* move out plugin validator ([47abe87](https://github.com/microfleet/core/commit/47abe87e8252eb427ee72de46d7e9740f2071ab5))
* plugin-cassandra ([2a53771](https://github.com/microfleet/core/commit/2a5377101a296bec97dddde1349c3de3c509aab9))
* plugin-http ([1e68ae1](https://github.com/microfleet/core/commit/1e68ae150b09d8656ee3f3518361970908994cd1))
* plugin-router-http ([70725f9](https://github.com/microfleet/core/commit/70725f9c1cab7a6766b92a8db9999e3624b69742))





## [2.6.6](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.6.5...@microfleet/plugin-kafka@2.6.6) (2021-04-15)

**Note:** Version bump only for package @microfleet/plugin-kafka





## [2.6.5](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.6.4...@microfleet/plugin-kafka@2.6.5) (2021-02-19)

**Note:** Version bump only for package @microfleet/plugin-kafka





## [2.6.4](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.6.3...@microfleet/plugin-kafka@2.6.4) (2020-09-03)

**Note:** Version bump only for package @microfleet/plugin-kafka





## [2.6.3](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.6.2...@microfleet/plugin-kafka@2.6.3) (2020-08-26)

**Note:** Version bump only for package @microfleet/plugin-kafka





## [2.6.2](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.6.1...@microfleet/plugin-kafka@2.6.2) (2020-08-25)

**Note:** Version bump only for package @microfleet/plugin-kafka





## [2.6.1](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.6.0...@microfleet/plugin-kafka@2.6.1) (2020-08-09)

**Note:** Version bump only for package @microfleet/plugin-kafka





# [2.6.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.5.2...@microfleet/plugin-kafka@2.6.0) (2020-07-28)


### Features

* response validation ([#438](https://github.com/microfleet/core/issues/438)) ([bbb2706](https://github.com/microfleet/core/commit/bbb27066eefaea1018c2a69ca05ec5936916c5b8))





## [2.5.2](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.5.1...@microfleet/plugin-kafka@2.5.2) (2020-07-22)

**Note:** Version bump only for package @microfleet/plugin-kafka





## [2.5.1](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.5.0...@microfleet/plugin-kafka@2.5.1) (2020-07-15)


### Bug Fixes

* change offset_commit_cb logic + error handler ([#437](https://github.com/microfleet/core/issues/437)) ([85d6e26](https://github.com/microfleet/core/commit/85d6e261db4b5509e495ddd914925abe18995b9e))





# [2.5.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.4.0...@microfleet/plugin-kafka@2.5.0) (2020-06-29)


### Bug Fixes

* unnecessary code ([0830282](https://github.com/microfleet/core/commit/0830282875de28c9512997e044851d784dac1387))


### Features

* admin client use blubird-retry ([88bc37e](https://github.com/microfleet/core/commit/88bc37e36ecbcf44bc1a965995a7fe6e74a8b6cb))





# [2.4.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.3.2...@microfleet/plugin-kafka@2.4.0) (2020-06-12)


### Features

* extra message filters and tester image ([#430](https://github.com/microfleet/core/issues/430)) ([1ae435a](https://github.com/microfleet/core/commit/1ae435aa331c0b80cf714e34cc13e8ae02296fba))





## [2.3.2](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.3.1...@microfleet/plugin-kafka@2.3.2) (2020-06-12)


### Bug Fixes

* improved types ([61859a9](https://github.com/microfleet/core/commit/61859a9e2c423f549931fa95445aa31848be2375))
* update deps ([bd2790a](https://github.com/microfleet/core/commit/bd2790aceed96561691faf954cfb2e1b52dfda65))





## [2.3.1](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.3.0...@microfleet/plugin-kafka@2.3.1) (2020-05-19)


### Bug Fixes

* jest 26 upgrade + plugin-kafka-types fix ([#426](https://github.com/microfleet/core/issues/426)) ([3b6a3b2](https://github.com/microfleet/core/commit/3b6a3b27c104873b3e3665b89b5e015e9929cf30))





# [2.3.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.2.2...@microfleet/plugin-kafka@2.3.0) (2020-05-15)


### Bug Fixes

* update dependencies ([24ecb3a](https://github.com/microfleet/core/commit/24ecb3ac3597de073095ce54305cc8ec707c1333))


### Features

* kafka admin client + some sugar ([#423](https://github.com/microfleet/core/issues/423)) ([0150da1](https://github.com/microfleet/core/commit/0150da14d9d136b5665f0e76cf82eadebeb1eeda))





## [2.2.2](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.2.1...@microfleet/plugin-kafka@2.2.2) (2020-04-29)


### Bug Fixes

* **plugin-kafka:** offsetsStore called using lower offsets ([#419](https://github.com/microfleet/core/issues/419)) ([621edc1](https://github.com/microfleet/core/commit/621edc135786fe373527a18558e965e1f51e9367))





## [2.2.1](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.2.0...@microfleet/plugin-kafka@2.2.1) (2020-04-28)

**Note:** Version bump only for package @microfleet/plugin-kafka





# [2.2.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.1.1...@microfleet/plugin-kafka@2.2.0) (2020-04-16)


### Features

* kafka custom stream ([#405](https://github.com/microfleet/core/issues/405)) ([2ce74d3](https://github.com/microfleet/core/commit/2ce74d3c92f57184acf4f7e8036518acbe8f5319))





## [2.1.1](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.1.0...@microfleet/plugin-kafka@2.1.1) (2020-04-10)

**Note:** Version bump only for package @microfleet/plugin-kafka





# [2.1.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@2.0.0...@microfleet/plugin-kafka@2.1.0) (2020-04-07)


### Features

* external logger module ([4bdbbac](https://github.com/microfleet/core/commit/4bdbbace81de1e3bc6bab6ef21ecaaff6a303ace))
* refactor to eslint ([2707e95](https://github.com/microfleet/core/commit/2707e95559581dd9f0d8efaf375e0f30c846acb9))





# [2.0.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@1.0.6...@microfleet/plugin-kafka@2.0.0) (2020-03-13)


### Bug Fixes

* microfleet/validation version bump ([#402](https://github.com/microfleet/core/issues/402)) ([9023c22](https://github.com/microfleet/core/commit/9023c22123476ea98079df6a1ae6c7039b7508a1))


### BREAKING CHANGES

* This fix bumps @microfleet/validation version





## [1.0.6](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@1.0.5...@microfleet/plugin-kafka@1.0.6) (2020-03-06)

**Note:** Version bump only for package @microfleet/plugin-kafka





## [1.0.5](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@1.0.4...@microfleet/plugin-kafka@1.0.5) (2020-03-06)


### Bug Fixes

* add missing exported types and method defs ([#398](https://github.com/microfleet/core/issues/398)) ([e4b31b3](https://github.com/microfleet/core/commit/e4b31b3141662ee3e15c6de6d7a9b2abcdb80777))





## [1.0.4](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@1.0.3...@microfleet/plugin-kafka@1.0.4) (2020-02-13)

**Note:** Version bump only for package @microfleet/plugin-kafka





## [1.0.3](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@1.0.2...@microfleet/plugin-kafka@1.0.3) (2020-02-05)


### Bug Fixes

* correct interfaces + extra types ([#387](https://github.com/microfleet/core/issues/387)) ([b5bed27](https://github.com/microfleet/core/commit/b5bed27fb9ca095cda0950e89a9ad831d23b2695))





## [1.0.2](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@1.0.1...@microfleet/plugin-kafka@1.0.2) (2020-01-24)

**Note:** Version bump only for package @microfleet/plugin-kafka





## [1.0.1](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@1.0.0...@microfleet/plugin-kafka@1.0.1) (2020-01-21)


### Bug Fixes

* package.json missing section ([#381](https://github.com/microfleet/core/issues/381)) ([915202b](https://github.com/microfleet/core/commit/915202b1f4465b72e1b1469b9aca471c9434f1c6))





# [1.0.0](https://github.com/microfleet/core/compare/@microfleet/plugin-kafka@0.2.0...@microfleet/plugin-kafka@1.0.0) (2020-01-21)


### Features

* upgrade all deps ([#380](https://github.com/microfleet/core/issues/380)) ([0e12454](https://github.com/microfleet/core/commit/0e12454cd78982eaaa77ea68a9fe6597404b702e))


### BREAKING CHANGES

* requires node 12+, uses @hapi/joi 17, @hapi/hapi 19, ms-conf & @makeomatic/confidence updates.
That would potentially require changes to service deployments





# 0.2.0 (2020-01-20)


### Features

* streaming based kafka plugin ([#362](https://github.com/microfleet/core/issues/362)) ([d82cda7](https://github.com/microfleet/core/commit/d82cda7b8d6ccbb2edd9129d5073188394fd4cf3))