{"_id":"@alti-js/nestjs-kafka","_rev":"15-34d96042d6a47df76af85055c4569fd4","name":"@alti-js/nestjs-kafka","dist-tags":{"latest":"0.6.2"},"versions":{"0.1.0":{"name":"@alti-js/nestjs-kafka","version":"0.1.0","keywords":["nestjs","kafkajs"],"author":{"name":"Angel Sanchez"},"license":"MIT","_id":"@alti-js/nestjs-kafka@0.1.0","maintainers":[{"name":"asanchez-altimetrik","email":"asanchez@altimetrik.com"}],"homepage":"https://github.com/alti-js/nestjs-kafka/#readme","bugs":{"url":"https://github.com/alti-js/nestjs-kafka/issues"},"dist":{"shasum":"e93d3d6e7954d9eff56ad8fb3c41302f9239545d","tarball":"https://registry.npmjs.org/@alti-js/nestjs-kafka/-/nestjs-kafka-0.1.0.tgz","fileCount":66,"integrity":"sha512-A7htOy0u5+WWTv3Xu63Akv59Wxf0itiMNyXV9QzHv7hhQOpH2oL6U/QFv6tJc4cd3UbqyjrsijjgUsU+7GuEsw==","signatures":[{"sig":"MEUCIHaJZDl1R7s3lKQ+oLQVJlcn8s2ymEz2mZJ8KDGTZUZfAiEA4R83E7cFH5F9TRK3G3GUsyfqCG+bh87Xcw2BKepcJkE=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":242795},"jest":{"rootDir":"src","testRegex":".spec.ts$","transform":{"^.+\\.(t|j)s$":"ts-jest"},"testEnvironment":"node","coverageDirectory":"../coverage","moduleFileExtensions":["js","json","ts"]},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"14c0815e4ee23a037f9c834b705e08bd49445703","scripts":{"lint":"eslint \"{src,apps,libs,test}/**/*.ts\" --fix","test":"jest","build":"nest build","prepare":"tsc --project tsconfig.build.json","test:cov":"jest --coverage","test:e2e":"jest --config ./test/jest-e2e.json --detectOpenHandles --runInBand","kafka:stop":"docker-compose -f ./kafka/docker-compose.yml down -v","test:debug":"node --inspect-brk -r tsconfig-paths/register -r ts-node/register node_modules/.bin/jest --runInBand","test:watch":"jest --watch","kafka:start":"docker-compose -f ./kafka/docker-compose.yml up -d"},"_npmUser":{"name":"asanchez-altimetrik","email":"asanchez@altimetrik.com"},"repository":{"url":"git+https://github.com/rob3000/nestjs-kafka.git","type":"git"},"_npmVersion":"9.8.1","description":"KafkaJS integration with NestJS","directories":{},"_nodeVersion":"18.18.0","dependencies":{"rxjs":"^7.8.1","kafkajs":"^1.15.0","@nestjs/core":"^10.4.15","@nestjs/common":"^10.4.15","reflect-metadata":"^0.2.0","@nestjs/microservices":"^10.4.15","@kafkajs/confluent-schema-registry":"^2.0.1"},"_hasShrinkwrap":false,"devDependencies":{"jest":"^29.5.0","eslint":"^8.0.0","ts-jest":"^29.1.0","ts-node":"^10.9.1","prettier":"^3.0.0","supertest":"^7.0.0","ts-loader":"^9.4.3","typescript":"^5.1.3","@nestjs/cli":"^10.0.0","@types/jest":"^29.5.2","@types/node":"^20.3.1","@types/express":"^5.0.0","tsconfig-paths":"^4.2.0","@nestjs/testing":"^10.0.0","@types/supertest":"^6.0.0","@nestjs/schematics":"^10.0.0","source-map-support":"^0.5.21","eslint-config-prettier":"^9.0.0","eslint-plugin-prettier":"^5.0.0","@typescript-eslint/parser":"^8.0.0","@typescript-eslint/eslint-plugin":"^8.0.0"},"_npmOperationalInternal":{"tmp":"tmp/nestjs-kafka_0.1.0_1734023318287_0.4773854812810885","host":"s3://npm-registry-packages-npm-production"}},"0.2.0":{"name":"@alti-js/nestjs-kafka","version":"0.2.0","keywords":["nestjs","kafkajs"],"author":{"name":"Angel Sanchez"},"license":"MIT","_id":"@alti-js/nestjs-kafka@0.2.0","maintainers":[{"name":"asanchez-altimetrik","email":"asanchez@altimetrik.com"}],"homepage":"https://github.com/alti-js/nestjs-kafka/#readme","bugs":{"url":"https://github.com/alti-js/nestjs-kafka/issues"},"dist":{"shasum":"5e2a738368d1b3d7eee5110383ffd45abb2e216f","tarball":"https://registry.npmjs.org/@alti-js/nestjs-kafka/-/nestjs-kafka-0.2.0.tgz","fileCount":66,"integrity":"sha512-9ugncxkDr6Q6yJ/xXED7jVfg2t1YaThpMyTZdy/FP4m5WpyUkXUBPvqdiIAOsGPV7N6BzgdCX3P0CgfH9LUj0g==","signatures":[{"sig":"MEQCIEugPiERAUOu7kfECybtN/Cz6vqiatoGzQnlSbwYvBRVAiBfc8rhHhQsMrzdR39ZVmh01WrxRVgiOtPtvh5Px3eZ9g==","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":242795},"jest":{"rootDir":"src","testRegex":".spec.ts$","transform":{"^.+\\.(t|j)s$":"ts-jest"},"testEnvironment":"node","coverageDirectory":"../coverage","moduleFileExtensions":["js","json","ts"]},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"23c95d5ed32e82b80c3ab5da7c941b2bd523a7fa","scripts":{"lint":"eslint \"{src,apps,libs,test}/**/*.ts\" --fix","test":"jest","build":"nest build","prepare":"tsc --project tsconfig.build.json","test:cov":"jest --coverage","test:e2e":"jest --config ./test/jest-e2e.json --detectOpenHandles --runInBand","kafka:stop":"docker-compose -f ./kafka/docker-compose.yml down -v","test:debug":"node --inspect-brk -r tsconfig-paths/register -r ts-node/register node_modules/.bin/jest --runInBand","test:watch":"jest --watch","kafka:start":"docker-compose -f ./kafka/docker-compose.yml up -d"},"_npmUser":{"name":"asanchez-altimetrik","email":"asanchez@altimetrik.com"},"repository":{"url":"git+https://github.com/alti-js/nestjs-kafka.git","type":"git"},"_npmVersion":"9.8.1","description":"KafkaJS integration with NestJS","directories":{},"_nodeVersion":"18.18.0","dependencies":{"rxjs":"^7.8.1","kafkajs":"^1.15.0","@nestjs/core":"^10.4.15","@nestjs/common":"^10.4.15","reflect-metadata":"^0.2.0","@nestjs/microservices":"^10.4.15","@kafkajs/confluent-schema-registry":"^2.0.1"},"_hasShrinkwrap":false,"devDependencies":{"jest":"^29.5.0","eslint":"^8.0.0","ts-jest":"^29.1.0","ts-node":"^10.9.1","prettier":"^3.0.0","supertest":"^7.0.0","ts-loader":"^9.4.3","typescript":"^5.1.3","@nestjs/cli":"^10.0.0","@types/jest":"^29.5.2","@types/node":"^20.3.1","@types/express":"^5.0.0","tsconfig-paths":"^4.2.0","@nestjs/testing":"^10.0.0","@types/supertest":"^6.0.0","@nestjs/schematics":"^10.0.0","source-map-support":"^0.5.21","eslint-config-prettier":"^9.0.0","eslint-plugin-prettier":"^5.0.0","@typescript-eslint/parser":"^8.0.0","@typescript-eslint/eslint-plugin":"^8.0.0"},"_npmOperationalInternal":{"tmp":"tmp/nestjs-kafka_0.2.0_1734025860652_0.7551444933672031","host":"s3://npm-registry-packages-npm-production"}},"0.3.0":{"name":"@alti-js/nestjs-kafka","version":"0.3.0","keywords":["nestjs","kafkajs"],"author":{"name":"Angel Sanchez"},"license":"MIT","_id":"@alti-js/nestjs-kafka@0.3.0","maintainers":[{"name":"asanchez-altimetrik","email":"asanchez@altimetrik.com"},{"name":"ankitkapadia","email":"akapadia@altimetrik.com"}],"homepage":"https://github.com/alti-js/nestjs-kafka/#readme","bugs":{"url":"https://github.com/alti-js/nestjs-kafka/issues"},"dist":{"shasum":"7e4bd08055397a845af4474e507eb93f3db6d9bd","tarball":"https://registry.npmjs.org/@alti-js/nestjs-kafka/-/nestjs-kafka-0.3.0.tgz","fileCount":66,"integrity":"sha512-bWHbd2BBsnSRwdoXpTR90BRFe9OYlf2F+1t/MY34AaOPAMwxnVR/X6cPkSDyCvw/aM4IKp8rJcb0JDF/ymkJjg==","signatures":[{"sig":"MEUCIHWRneQDQ2KSm7lhj+mpy9cZ6xrO9IWTsJUdUcKhoCxmAiEA+TLGw8lOVpxg5UJpoEQXCQffZ58RP5al91wsigbIHzA=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":243652},"jest":{"rootDir":"src","testRegex":".spec.ts$","transform":{"^.+\\.(t|j)s$":"ts-jest"},"testEnvironment":"node","coverageDirectory":"../coverage","moduleFileExtensions":["js","json","ts"]},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"3a9e535913a7c6b39409b420483849520757806d","scripts":{"lint":"eslint \"{src,apps,libs,test}/**/*.ts\" --fix","test":"jest","build":"nest build","prepare":"tsc --project tsconfig.build.json","test:cov":"jest --coverage","test:e2e":"jest --config ./test/jest-e2e.json --detectOpenHandles --runInBand","kafka:stop":"docker-compose -f ./kafka/docker-compose.yml down -v","test:debug":"node --inspect-brk -r tsconfig-paths/register -r ts-node/register node_modules/.bin/jest --runInBand","test:watch":"jest --watch","kafka:start":"docker-compose -f ./kafka/docker-compose.yml up -d"},"_npmUser":{"name":"asanchez-altimetrik","email":"asanchez@altimetrik.com"},"repository":{"url":"git+https://github.com/alti-js/nestjs-kafka.git","type":"git"},"_npmVersion":"9.8.1","description":"KafkaJS integration with NestJS","directories":{},"_nodeVersion":"18.18.0","dependencies":{"rxjs":"^7.8.1","kafkajs":"^1.15.0","@nestjs/core":"^10.4.15","@nestjs/common":"^10.4.15","reflect-metadata":"^0.2.0","@nestjs/microservices":"^10.4.15","@kafkajs/confluent-schema-registry":"^2.0.1"},"_hasShrinkwrap":false,"devDependencies":{"jest":"^29.5.0","eslint":"^8.0.0","ts-jest":"^29.1.0","ts-node":"^10.9.1","prettier":"^3.0.0","supertest":"^7.0.0","ts-loader":"^9.4.3","typescript":"^5.1.3","@nestjs/cli":"^10.0.0","@types/jest":"^29.5.2","@types/node":"^20.3.1","@types/express":"^5.0.0","tsconfig-paths":"^4.2.0","@nestjs/testing":"^10.0.0","@types/supertest":"^6.0.0","@nestjs/schematics":"^10.0.0","source-map-support":"^0.5.21","eslint-config-prettier":"^9.0.0","eslint-plugin-prettier":"^5.0.0","@typescript-eslint/parser":"^8.0.0","@typescript-eslint/eslint-plugin":"^8.0.0"},"_npmOperationalInternal":{"tmp":"tmp/nestjs-kafka_0.3.0_1745226847350_0.7347785109844842","host":"s3://npm-registry-packages-npm-production"}},"0.4.0":{"name":"@alti-js/nestjs-kafka","version":"0.4.0","keywords":["nestjs","kafkajs"],"author":{"name":"Angel Sanchez"},"license":"MIT","_id":"@alti-js/nestjs-kafka@0.4.0","maintainers":[{"name":"asanchez-altimetrik","email":"asanchez@altimetrik.com"},{"name":"ankitkapadia","email":"akapadia@altimetrik.com"}],"homepage":"https://github.com/alti-js/nestjs-kafka/#readme","bugs":{"url":"https://github.com/alti-js/nestjs-kafka/issues"},"dist":{"shasum":"5ff4de7a2d86f7be25fc486129c280b049419af7","tarball":"https://registry.npmjs.org/@alti-js/nestjs-kafka/-/nestjs-kafka-0.4.0.tgz","fileCount":66,"integrity":"sha512-B6F5Y/c28oXEEE5hKkQ4pi8HRKRhMiCRITwvEWHo5SxR0sxvwMk7jmvkbravNZizXKzvjyElq39Ks6C/BBsLvg==","signatures":[{"sig":"MEUCIQDGjO2pUdqbb8uk9nV0w/TpZhu3uEWl4ayhRVO715mLuQIgMYP0TvNLZaHuKagYA1bdTp0RTI5KARqqB5yD7BWfzLQ=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":242984},"jest":{"rootDir":"src","testRegex":".spec.ts$","transform":{"^.+\\.(t|j)s$":"ts-jest"},"testEnvironment":"node","coverageDirectory":"../coverage","moduleFileExtensions":["js","json","ts"]},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"e3ef9d95fa299b012660c65d63fcfa6cb91daed0","scripts":{"lint":"eslint \"{src,apps,libs,test}/**/*.ts\" --fix","test":"jest","build":"nest build","prepare":"tsc --project tsconfig.build.json","test:cov":"jest --coverage","test:e2e":"jest --config ./test/jest-e2e.json --detectOpenHandles --runInBand","kafka:stop":"docker-compose -f ./kafka/docker-compose.yml down -v","test:debug":"node --inspect-brk -r tsconfig-paths/register -r ts-node/register node_modules/.bin/jest --runInBand","test:watch":"jest --watch","kafka:start":"docker-compose -f ./kafka/docker-compose.yml up -d"},"_npmUser":{"name":"asanchez-altimetrik","email":"asanchez@altimetrik.com"},"repository":{"url":"git+https://github.com/alti-js/nestjs-kafka.git","type":"git"},"_npmVersion":"9.8.1","description":"KafkaJS integration with NestJS","directories":{},"_nodeVersion":"18.18.0","dependencies":{"rxjs":"^7.8.1","kafkajs":"^1.15.0","@nestjs/core":"^10.4.15","@nestjs/common":"^10.4.15","reflect-metadata":"^0.2.0","@nestjs/microservices":"^10.4.15","@kafkajs/confluent-schema-registry":"^2.0.1"},"_hasShrinkwrap":false,"devDependencies":{"jest":"^29.5.0","eslint":"^8.0.0","ts-jest":"^29.1.0","ts-node":"^10.9.1","prettier":"^3.0.0","supertest":"^7.0.0","ts-loader":"^9.4.3","typescript":"^5.1.3","@nestjs/cli":"^10.0.0","@types/jest":"^29.5.2","@types/node":"^20.3.1","@types/express":"^5.0.0","tsconfig-paths":"^4.2.0","@nestjs/testing":"^10.0.0","@types/supertest":"^6.0.0","@nestjs/schematics":"^10.0.0","source-map-support":"^0.5.21","eslint-config-prettier":"^9.0.0","eslint-plugin-prettier":"^5.0.0","@typescript-eslint/parser":"^8.0.0","@typescript-eslint/eslint-plugin":"^8.0.0"},"_npmOperationalInternal":{"tmp":"tmp/nestjs-kafka_0.4.0_1745347300067_0.19025217390602855","host":"s3://npm-registry-packages-npm-production"}},"0.5.0":{"name":"@alti-js/nestjs-kafka","version":"0.5.0","keywords":["nestjs","kafkajs"],"author":{"name":"Angel Sanchez"},"license":"MIT","_id":"@alti-js/nestjs-kafka@0.5.0","maintainers":[{"name":"asanchez-altimetrik","email":"asanchez@altimetrik.com"},{"name":"ankitkapadia","email":"akapadia@altimetrik.com"}],"homepage":"https://github.com/alti-js/nestjs-kafka/#readme","bugs":{"url":"https://github.com/alti-js/nestjs-kafka/issues"},"dist":{"shasum":"9337f5b10a733139b0db705942c2cd170b7650cb","tarball":"https://registry.npmjs.org/@alti-js/nestjs-kafka/-/nestjs-kafka-0.5.0.tgz","fileCount":66,"integrity":"sha512-rfF02nM8FudySk8kKsZCs7AzSERrY3bPz9Qz7jpyQuTFnGpNIW+A043Rz4Z0dnJPS2znCv5cgS4u7/DTnl/1gQ==","signatures":[{"sig":"MEUCIQDUzojBr6Hy4GITPDVGFpyr1ZEjmnJeOCCoWNsq+W5rZwIgF1JoOSlswKnld945kYTlnY3/xCWJpbDv7TBHxRBXQBU=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":242787},"jest":{"rootDir":"src","testRegex":".spec.ts$","transform":{"^.+\\.(t|j)s$":"ts-jest"},"testEnvironment":"node","coverageDirectory":"../coverage","moduleFileExtensions":["js","json","ts"]},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"6c8d807ba5924d6a39638b83074368740feb8950","scripts":{"lint":"eslint \"{src,apps,libs,test}/**/*.ts\" --fix","test":"jest","build":"nest build","prepare":"tsc --project tsconfig.build.json","test:cov":"jest --coverage","test:e2e":"jest --config ./test/jest-e2e.json --detectOpenHandles --runInBand","kafka:stop":"docker-compose -f ./kafka/docker-compose.yml down -v","test:debug":"node --inspect-brk -r tsconfig-paths/register -r ts-node/register node_modules/.bin/jest --runInBand","test:watch":"jest --watch","kafka:start":"docker-compose -f ./kafka/docker-compose.yml up -d"},"_npmUser":{"name":"asanchez-altimetrik","email":"asanchez@altimetrik.com"},"repository":{"url":"git+https://github.com/alti-js/nestjs-kafka.git","type":"git"},"_npmVersion":"9.8.1","description":"KafkaJS integration with NestJS","directories":{},"_nodeVersion":"18.18.0","dependencies":{"rxjs":"^7.8.1","kafkajs":"^1.15.0","@nestjs/core":"^10.4.15","@nestjs/common":"^10.4.15","reflect-metadata":"^0.2.0","@nestjs/microservices":"^10.4.15","@kafkajs/confluent-schema-registry":"^2.0.1"},"_hasShrinkwrap":false,"devDependencies":{"jest":"^29.5.0","eslint":"^8.0.0","ts-jest":"^29.1.0","ts-node":"^10.9.1","prettier":"^3.0.0","supertest":"^7.0.0","ts-loader":"^9.4.3","typescript":"^5.1.3","@nestjs/cli":"^10.0.0","@types/jest":"^29.5.2","@types/node":"^20.3.1","@types/express":"^5.0.0","tsconfig-paths":"^4.2.0","@nestjs/testing":"^10.0.0","@types/supertest":"^6.0.0","@nestjs/schematics":"^10.0.0","source-map-support":"^0.5.21","eslint-config-prettier":"^9.0.0","eslint-plugin-prettier":"^5.0.0","@typescript-eslint/parser":"^8.0.0","@typescript-eslint/eslint-plugin":"^8.0.0"},"_npmOperationalInternal":{"tmp":"tmp/nestjs-kafka_0.5.0_1745384053809_0.5714104065824488","host":"s3://npm-registry-packages-npm-production"}},"0.6.0":{"name":"@alti-js/nestjs-kafka","version":"0.6.0","keywords":["nestjs","kafkajs"],"author":{"name":"Angel Sanchez"},"license":"MIT","_id":"@alti-js/nestjs-kafka@0.6.0","maintainers":[{"name":"asanchez-altimetrik","email":"asanchez@altimetrik.com"},{"name":"ankitkapadia","email":"akapadia@altimetrik.com"}],"homepage":"https://github.com/alti-js/nestjs-kafka/#readme","bugs":{"url":"https://github.com/alti-js/nestjs-kafka/issues"},"dist":{"shasum":"f419204700bdebfc105c20b86225a393fdac8eaa","tarball":"https://registry.npmjs.org/@alti-js/nestjs-kafka/-/nestjs-kafka-0.6.0.tgz","fileCount":66,"integrity":"sha512-K9IHzHj+ijhY4PbuX6PYTGPwI0aAyBxhoXuibPamT+o9atdlXSSzkgdmT6bHe0cBvfs0qR4hShNPTdZ6i0KMKg==","signatures":[{"sig":"MEUCIQCKhwsZ+vNiNZeqJ1N5PxzqZrTon8nPmxrS7gIKlS9VQAIgFzPqYPREaEv+LtkbBhLb1YrM2HLa75Ar5JVMJ6U/Sfo=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":242501},"jest":{"rootDir":"src","testRegex":".spec.ts$","transform":{"^.+\\.(t|j)s$":"ts-jest"},"testEnvironment":"node","coverageDirectory":"../coverage","moduleFileExtensions":["js","json","ts"]},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"fa1f1e677cf03d8283905e42f546cc5558c078a2","scripts":{"lint":"eslint \"{src,apps,libs,test}/**/*.ts\" --fix","test":"jest","build":"nest build","prepare":"tsc --project tsconfig.build.json","test:cov":"jest --coverage","test:e2e":"jest --config ./test/jest-e2e.json --detectOpenHandles --runInBand","kafka:stop":"docker-compose -f ./kafka/docker-compose.yml down -v","test:debug":"node --inspect-brk -r tsconfig-paths/register -r ts-node/register node_modules/.bin/jest --runInBand","test:watch":"jest --watch","kafka:start":"docker-compose -f ./kafka/docker-compose.yml up -d"},"_npmUser":{"name":"asanchez-altimetrik","email":"asanchez@altimetrik.com"},"repository":{"url":"git+https://github.com/alti-js/nestjs-kafka.git","type":"git"},"_npmVersion":"9.8.1","description":"KafkaJS integration with NestJS","directories":{},"_nodeVersion":"18.18.0","dependencies":{"rxjs":"^7.8.1","kafkajs":"^1.15.0","@nestjs/core":"^10.4.15","@nestjs/common":"^10.4.15","reflect-metadata":"^0.2.0","@nestjs/microservices":"^10.4.15","@kafkajs/confluent-schema-registry":"^2.0.1"},"_hasShrinkwrap":false,"devDependencies":{"jest":"^29.5.0","eslint":"^8.0.0","ts-jest":"^29.1.0","ts-node":"^10.9.1","prettier":"^3.0.0","supertest":"^7.0.0","ts-loader":"^9.4.3","typescript":"^5.1.3","@nestjs/cli":"^10.0.0","@types/jest":"^29.5.2","@types/node":"^20.3.1","@types/express":"^5.0.0","tsconfig-paths":"^4.2.0","@nestjs/testing":"^10.0.0","@types/supertest":"^6.0.0","@nestjs/schematics":"^10.0.0","source-map-support":"^0.5.21","eslint-config-prettier":"^9.0.0","eslint-plugin-prettier":"^5.0.0","@typescript-eslint/parser":"^8.0.0","@typescript-eslint/eslint-plugin":"^8.0.0"},"_npmOperationalInternal":{"tmp":"tmp/nestjs-kafka_0.6.0_1745411964599_0.5922975258227519","host":"s3://npm-registry-packages-npm-production"}},"0.6.1":{"name":"@alti-js/nestjs-kafka","version":"0.6.1","keywords":["nestjs","kafkajs"],"author":{"name":"Angel Sanchez"},"license":"MIT","_id":"@alti-js/nestjs-kafka@0.6.1","maintainers":[{"name":"asanchez-altimetrik","email":"asanchez@altimetrik.com"},{"name":"ankitkapadia","email":"akapadia@altimetrik.com"},{"name":"landrukanis","email":"landrukanis@altimetrik.com"}],"homepage":"https://github.com/alti-js/nestjs-kafka/#readme","bugs":{"url":"https://github.com/alti-js/nestjs-kafka/issues"},"dist":{"shasum":"113d71624d477e85ef59f7b6141eaf5d8c4657ae","tarball":"https://registry.npmjs.org/@alti-js/nestjs-kafka/-/nestjs-kafka-0.6.1.tgz","fileCount":66,"integrity":"sha512-TSWuYh68LphLsYJnxkSylW49x0NJK6MFjXNrTYH/5uSfSDQr3XQSwV8rC9jjj4flqyTgcM1GhMNU7BtlUP9zEQ==","signatures":[{"sig":"MEYCIQC0XWglDkcP7fBSV4nZZXrH79yyMpJQ2OXWLXPsRxwIigIhAMxNfJyrZxLEKD2e6hayTPSsNRpVHnEpZu+Jf55topfI","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":242501},"jest":{"rootDir":"src","testRegex":".spec.ts$","transform":{"^.+\\.(t|j)s$":"ts-jest"},"testEnvironment":"node","coverageDirectory":"../coverage","moduleFileExtensions":["js","json","ts"]},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"b3652eefaf9df873ca2d1d1cfa2e741eb753b5e2","scripts":{"lint":"eslint \"{src,apps,libs,test}/**/*.ts\" --fix","test":"jest","build":"nest build","prepare":"tsc --project tsconfig.build.json","test:cov":"jest --coverage","test:e2e":"jest --config ./test/jest-e2e.json --detectOpenHandles --runInBand","kafka:stop":"docker-compose -f ./kafka/docker-compose.yml down -v","test:debug":"node --inspect-brk -r tsconfig-paths/register -r ts-node/register node_modules/.bin/jest --runInBand","test:watch":"jest --watch","kafka:start":"docker-compose -f ./kafka/docker-compose.yml up -d"},"_npmUser":{"name":"asanchez-altimetrik","email":"asanchez@altimetrik.com"},"repository":{"url":"git+https://github.com/alti-js/nestjs-kafka.git","type":"git"},"_npmVersion":"10.8.2","description":"KafkaJS integration with NestJS","directories":{},"_nodeVersion":"20.19.1","dependencies":{"rxjs":"^7.8.1","kafkajs":"^1.15.0","@nestjs/core":"^10.4.15","@nestjs/common":"^10.4.15","reflect-metadata":"^0.2.0","@nestjs/microservices":"^10.4.15","@kafkajs/confluent-schema-registry":"^2.0.1"},"_hasShrinkwrap":false,"devDependencies":{"jest":"^29.5.0","eslint":"^8.0.0","ts-jest":"^29.1.0","ts-node":"^10.9.1","prettier":"^3.0.0","supertest":"^7.0.0","ts-loader":"^9.4.3","typescript":"^5.1.3","@nestjs/cli":"^10.0.0","@types/jest":"^29.5.2","@types/node":"^20.3.1","@types/express":"^5.0.0","tsconfig-paths":"^4.2.0","@nestjs/testing":"^10.0.0","@types/supertest":"^6.0.0","@nestjs/schematics":"^10.0.0","source-map-support":"^0.5.21","eslint-config-prettier":"^9.0.0","eslint-plugin-prettier":"^5.0.0","@typescript-eslint/parser":"^8.0.0","@typescript-eslint/eslint-plugin":"^8.0.0"},"_npmOperationalInternal":{"tmp":"tmp/nestjs-kafka_0.6.1_1748353598739_0.7403401184312541","host":"s3://npm-registry-packages-npm-production"}},"0.6.4":{"name":"@alti-js/nestjs-kafka","version":"0.6.4","keywords":["nestjs","kafkajs"],"author":{"name":"Angel Sanchez"},"license":"MIT","_id":"@alti-js/nestjs-kafka@0.6.4","maintainers":[{"name":"asanchez-altimetrik","email":"asanchez@altimetrik.com"},{"name":"ankitkapadia","email":"akapadia@altimetrik.com"},{"name":"landrukanis","email":"landrukanis@altimetrik.com"},{"name":"praveenalti","email":"psurendran@altimetrik.com"},{"name":"sguhaprasad","email":"sguhaprasad@altimetrik.com"}],"homepage":"https://github.com/alti-js/nestjs-kafka/#readme","bugs":{"url":"https://github.com/alti-js/nestjs-kafka/issues"},"dist":{"shasum":"2322065034c1d5e22b3d1e2fecdc88ac9d045209","tarball":"https://registry.npmjs.org/@alti-js/nestjs-kafka/-/nestjs-kafka-0.6.4.tgz","fileCount":38,"integrity":"sha512-QQ0CO82uTchXt5TwoFyvO5PBYoTrO8cFu7AH5t/pVLH1+gLWtlCfQbDAldyIJgq7HtfwksYMim1tdQNl7Wntew==","signatures":[{"sig":"MEUCIQD+LB1fuwSI3Ejc0gubfTmUCbMFVdUCOaozfpTPP5RqYQIgSk6X9gIq8VqCkRIR+YKOkRpge19qd5DxlzUGAXkfktw=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":57999},"jest":{"rootDir":"src","testRegex":".spec.ts$","transform":{"^.+\\.(t|j)s$":"ts-jest"},"testEnvironment":"node","coverageDirectory":"../coverage","moduleFileExtensions":["js","json","ts"]},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"8a3c16a211a4d65ce789667813e8ed57bd83e792","scripts":{"lint":"eslint \"{src,apps,libs,test}/**/*.ts\" --fix","test":"jest","build":"nest build","prepare":"tsc --project tsconfig.build.json","test:cov":"jest --coverage","test:e2e":"jest --config ./test/jest-e2e.json --detectOpenHandles --runInBand","kafka:stop":"docker-compose -f ./kafka/docker-compose.yml down -v","test:debug":"node --inspect-brk -r tsconfig-paths/register -r ts-node/register node_modules/.bin/jest --runInBand","test:watch":"jest --watch","kafka:start":"docker-compose -f ./kafka/docker-compose.yml up -d"},"_npmUser":{"name":"asanchez-altimetrik","email":"asanchez@altimetrik.com"},"repository":{"url":"git+https://github.com/alti-js/nestjs-kafka.git","type":"git"},"_npmVersion":"10.8.2","description":"KafkaJS integration with NestJS","directories":{},"_nodeVersion":"18.20.8","dependencies":{"rxjs":"^7.8.1","kafkajs":"^1.15.0","@nestjs/core":"^10.4.15","@nestjs/common":"^10.4.15","reflect-metadata":"^0.2.0","@nestjs/microservices":"^10.4.15","@kafkajs/confluent-schema-registry":"^2.0.1"},"_hasShrinkwrap":false,"devDependencies":{"jest":"^29.5.0","eslint":"^8.0.0","ts-jest":"^29.1.0","ts-node":"^10.9.1","prettier":"^3.0.0","supertest":"^7.0.0","ts-loader":"^9.4.3","typescript":"^5.1.3","@nestjs/cli":"^10.0.0","@types/jest":"^29.5.2","@types/node":"^20.3.1","@types/express":"^5.0.0","tsconfig-paths":"^4.2.0","@nestjs/testing":"^10.0.0","@types/supertest":"^6.0.0","@nestjs/schematics":"^10.0.0","source-map-support":"^0.5.21","eslint-config-prettier":"^9.0.0","eslint-plugin-prettier":"^5.0.0","@typescript-eslint/parser":"^8.0.0","@typescript-eslint/eslint-plugin":"^8.0.0"},"_npmOperationalInternal":{"tmp":"tmp/nestjs-kafka_0.6.4_1760023821561_0.9437572315192242","host":"s3://npm-registry-packages-npm-production"}},"0.6.5":{"name":"@alti-js/nestjs-kafka","version":"0.6.5","keywords":["nestjs","kafkajs"],"author":{"name":"Angel Sanchez"},"license":"MIT","_id":"@alti-js/nestjs-kafka@0.6.5","maintainers":[{"name":"asanchez-altimetrik","email":"asanchez@altimetrik.com"},{"name":"ankitkapadia","email":"akapadia@altimetrik.com"},{"name":"landrukanis","email":"landrukanis@altimetrik.com"},{"name":"praveenalti","email":"psurendran@altimetrik.com"},{"name":"sguhaprasad","email":"sguhaprasad@altimetrik.com"}],"homepage":"https://github.com/alti-js/nestjs-kafka/#readme","bugs":{"url":"https://github.com/alti-js/nestjs-kafka/issues"},"dist":{"shasum":"66a8b59b07fcf366144912be16a4a9417483b85b","tarball":"https://registry.npmjs.org/@alti-js/nestjs-kafka/-/nestjs-kafka-0.6.5.tgz","fileCount":38,"integrity":"sha512-gANyE6I+lXRxo0CAeLXPTtb/AUG8GvIsMu0v6/r926tF4a5xMFPZc8ad8bl6GojRAQMS9i3L7MvE4cPA3hQ6Sw==","signatures":[{"sig":"MEUCIQDJTFTYlqJT/XvZtxvjqWAB5NSj/J95rN9DkkhEH83GFwIgDPxTsGphCVHbNkMH/x3BlkBxCktSy0NSDiDgSYCeS0I=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":57999},"jest":{"rootDir":"src","testRegex":".spec.ts$","transform":{"^.+\\.(t|j)s$":"ts-jest"},"testEnvironment":"node","coverageDirectory":"../coverage","moduleFileExtensions":["js","json","ts"]},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"3574a9e18bca119027ce63d9da6ff252f932b795","scripts":{"lint":"eslint \"{src,apps,libs,test}/**/*.ts\" --fix","test":"jest","build":"nest build","prepare":"tsc --project tsconfig.build.json","test:cov":"jest --coverage","test:e2e":"jest --config ./test/jest-e2e.json --detectOpenHandles --runInBand","kafka:stop":"docker-compose -f ./kafka/docker-compose.yml down -v","test:debug":"node --inspect-brk -r tsconfig-paths/register -r ts-node/register node_modules/.bin/jest --runInBand","test:watch":"jest --watch","kafka:start":"docker-compose -f ./kafka/docker-compose.yml up -d"},"_npmUser":{"name":"asanchez-altimetrik","email":"asanchez@altimetrik.com"},"repository":{"url":"git+https://github.com/alti-js/nestjs-kafka.git","type":"git"},"_npmVersion":"10.8.2","description":"KafkaJS integration with NestJS","directories":{},"_nodeVersion":"18.20.8","dependencies":{"rxjs":"^7.8.1","kafkajs":"^1.15.0","@nestjs/core":"^10.4.15","@nestjs/common":"^10.4.15","reflect-metadata":"^0.2.0","@nestjs/microservices":"^10.4.15","@kafkajs/confluent-schema-registry":"^2.0.1"},"_hasShrinkwrap":false,"devDependencies":{"jest":"^29.5.0","eslint":"^8.0.0","ts-jest":"^29.1.0","ts-node":"^10.9.1","prettier":"^3.0.0","supertest":"^7.0.0","ts-loader":"^9.4.3","typescript":"^5.1.3","@nestjs/cli":"^10.0.0","@types/jest":"^29.5.2","@types/node":"^20.3.1","@types/express":"^5.0.0","tsconfig-paths":"^4.2.0","@nestjs/testing":"^10.0.0","@types/supertest":"^6.0.0","@nestjs/schematics":"^10.0.0","source-map-support":"^0.5.21","eslint-config-prettier":"^9.0.0","eslint-plugin-prettier":"^5.0.0","@typescript-eslint/parser":"^8.0.0","@typescript-eslint/eslint-plugin":"^8.0.0"},"_npmOperationalInternal":{"tmp":"tmp/nestjs-kafka_0.6.5_1760023904869_0.01075415471114205","host":"s3://npm-registry-packages-npm-production"}},"0.6.3":{"name":"@alti-js/nestjs-kafka","version":"0.6.3","keywords":["nestjs","kafkajs"],"author":{"name":"Angel Sanchez"},"license":"MIT","_id":"@alti-js/nestjs-kafka@0.6.3","maintainers":[{"name":"asanchez-altimetrik","email":"asanchez@altimetrik.com"},{"name":"ankitkapadia","email":"akapadia@altimetrik.com"},{"name":"landrukanis","email":"landrukanis@altimetrik.com"},{"name":"praveenalti","email":"psurendran@altimetrik.com"},{"name":"sguhaprasad","email":"sguhaprasad@altimetrik.com"}],"homepage":"https://github.com/alti-js/nestjs-kafka/#readme","bugs":{"url":"https://github.com/alti-js/nestjs-kafka/issues"},"dist":{"shasum":"d3efb0f95fd38a27d61194590df3fb10e196bfb9","tarball":"https://registry.npmjs.org/@alti-js/nestjs-kafka/-/nestjs-kafka-0.6.3.tgz","fileCount":38,"integrity":"sha512-uBcXy3ygl/fAkR2fLGpTuBFx6hXQ4Lk0jLWQmfpqRgY7UEJEGoa+R34DKVugwBumXC3eH26V2pCpAd2s65KkXg==","signatures":[{"sig":"MEQCICd2NsWrFrKku4DlXEkQb9Z0bJfqyOlPNIYfT/Eu0iRZAiAjX19t3uAwHbkJMyoy0ZTYNXifbakYQ6MkFmTIzsAQ9Q==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":57999},"jest":{"rootDir":"src","testRegex":".spec.ts$","transform":{"^.+\\.(t|j)s$":"ts-jest"},"testEnvironment":"node","coverageDirectory":"../coverage","moduleFileExtensions":["js","json","ts"]},"main":"dist/index.js","types":"dist/index.d.ts","gitHead":"f77fdbf19ec932fffaab82348194275f7efa1427","scripts":{"lint":"eslint \"{src,apps,libs,test}/**/*.ts\" --fix","test":"jest","build":"nest build","prepare":"tsc --project tsconfig.build.json","test:cov":"jest --coverage","test:e2e":"jest --config ./test/jest-e2e.json --detectOpenHandles --runInBand","kafka:stop":"docker-compose -f ./kafka/docker-compose.yml down -v","test:debug":"node --inspect-brk -r tsconfig-paths/register -r ts-node/register node_modules/.bin/jest --runInBand","test:watch":"jest --watch","kafka:start":"docker-compose -f ./kafka/docker-compose.yml up -d"},"_npmUser":{"name":"asanchez-altimetrik","email":"asanchez@altimetrik.com"},"repository":{"url":"git+https://github.com/alti-js/nestjs-kafka.git","type":"git"},"_npmVersion":"10.8.2","description":"KafkaJS integration with NestJS","directories":{},"_nodeVersion":"18.20.8","dependencies":{"rxjs":"^7.8.1","kafkajs":"^1.15.0","@nestjs/core":"^10.4.15","@nestjs/common":"^10.4.15","reflect-metadata":"^0.2.0","@nestjs/microservices":"^10.4.15","@kafkajs/confluent-schema-registry":"^2.0.1"},"_hasShrinkwrap":false,"devDependencies":{"jest":"^29.5.0","eslint":"^8.0.0","ts-jest":"^29.1.0","ts-node":"^10.9.1","prettier":"^3.0.0","supertest":"^7.0.0","ts-loader":"^9.4.3","typescript":"^5.1.3","@nestjs/cli":"^10.0.0","@types/jest":"^29.5.2","@types/node":"^20.3.1","@types/express":"^5.0.0","tsconfig-paths":"^4.2.0","@nestjs/testing":"^10.0.0","@types/supertest":"^6.0.0","@nestjs/schematics":"^10.0.0","source-map-support":"^0.5.21","eslint-config-prettier":"^9.0.0","eslint-plugin-prettier":"^5.0.0","@typescript-eslint/parser":"^8.0.0","@typescript-eslint/eslint-plugin":"^8.0.0"},"_npmOperationalInternal":{"tmp":"tmp/nestjs-kafka_0.6.3_1760024883379_0.9243577313989859","host":"s3://npm-registry-packages-npm-production"}},"0.6.2":{"name":"@alti-js/nestjs-kafka","version":"0.6.2","description":"KafkaJS integration with NestJS","main":"dist/index.js","types":"dist/index.d.ts","scripts":{"build":"nest build","prepare":"tsc --project tsconfig.build.json","test":"jest","lint":"eslint \"{src,apps,libs,test}/**/*.ts\" --fix","kafka:start":"docker-compose -f ./kafka/docker-compose.yml up -d","kafka:stop":"docker-compose -f ./kafka/docker-compose.yml down -v","test:watch":"jest --watch","test:cov":"jest --coverage","test:debug":"node --inspect-brk -r tsconfig-paths/register -r ts-node/register node_modules/.bin/jest --runInBand","test:e2e":"jest --config ./test/jest-e2e.json --detectOpenHandles --runInBand"},"repository":{"type":"git","url":"git+https://github.com/alti-js/nestjs-kafka.git"},"keywords":["nestjs","kafkajs"],"author":{"name":"Angel Sanchez"},"license":"MIT","bugs":{"url":"https://github.com/alti-js/nestjs-kafka/issues"},"homepage":"https://github.com/alti-js/nestjs-kafka/#readme","dependencies":{"@kafkajs/confluent-schema-registry":"^2.0.1","@nestjs/common":"^10.4.15","@nestjs/core":"^10.4.15","@nestjs/microservices":"^10.4.15","kafkajs":"^1.15.0","reflect-metadata":"^0.2.0","rxjs":"^7.8.1"},"devDependencies":{"@nestjs/cli":"^10.0.0","@nestjs/schematics":"^10.0.0","@nestjs/testing":"^10.0.0","@types/express":"^5.0.0","@types/jest":"^29.5.2","@types/node":"^20.3.1","@types/supertest":"^6.0.0","@typescript-eslint/eslint-plugin":"^8.0.0","@typescript-eslint/parser":"^8.0.0","eslint":"^8.0.0","eslint-config-prettier":"^9.0.0","eslint-plugin-prettier":"^5.0.0","jest":"^29.5.0","prettier":"^3.0.0","source-map-support":"^0.5.21","supertest":"^7.0.0","ts-jest":"^29.1.0","ts-loader":"^9.4.3","ts-node":"^10.9.1","tsconfig-paths":"^4.2.0","typescript":"^5.1.3"},"jest":{"moduleFileExtensions":["js","json","ts"],"rootDir":"src","testRegex":".spec.ts$","transform":{"^.+\\.(t|j)s$":"ts-jest"},"coverageDirectory":"../coverage","testEnvironment":"node"},"_id":"@alti-js/nestjs-kafka@0.6.2","gitHead":"93533f6ee5aa1734923a231046bc495676843984","_nodeVersion":"18.20.8","_npmVersion":"10.8.2","dist":{"integrity":"sha512-bo2ckiVEmlQxNVRSHuMOVTNvNV5b2c8Vzb1m20D5Lr6GUtVyRIIYUOIAQIL67yO8MaW+W/Dyaweh1v2qZb5HYg==","shasum":"be34608bd7d552d6ef0c765a8f474337e39e01e8","tarball":"https://registry.npmjs.org/@alti-js/nestjs-kafka/-/nestjs-kafka-0.6.2.tgz","fileCount":38,"unpackedSize":57999,"signatures":[{"keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U","sig":"MEUCIGnhg6PAOJ+i0I96RIFZai5WmN4+EcGLSOckoeaw2IPUAiEA7mbxetNTy+gUnqjvnVD5Ht1J4J2WwWeiwZsTf0IpJqY="}]},"_npmUser":{"name":"asanchez-altimetrik","email":"asanchez@altimetrik.com"},"directories":{},"maintainers":[{"name":"asanchez-altimetrik","email":"asanchez@altimetrik.com"},{"name":"ankitkapadia","email":"akapadia@altimetrik.com"},{"name":"landrukanis","email":"landrukanis@altimetrik.com"},{"name":"praveenalti","email":"psurendran@altimetrik.com"},{"name":"sguhaprasad","email":"sguhaprasad@altimetrik.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages-npm-production","tmp":"tmp/nestjs-kafka_0.6.2_1760029395377_0.6924269689891833"},"_hasShrinkwrap":false}},"time":{"created":"2024-12-12T17:08:38.164Z","modified":"2025-10-09T17:03:15.854Z","0.1.0":"2024-12-12T17:08:38.558Z","0.2.0":"2024-12-12T17:51:00.864Z","0.3.0":"2025-04-21T09:14:07.596Z","0.4.0":"2025-04-22T18:41:40.323Z","0.5.0":"2025-04-23T04:54:14.037Z","0.6.0":"2025-04-23T12:39:24.790Z","0.6.1":"2025-05-27T13:46:39.075Z","0.6.4":"2025-10-09T15:30:21.770Z","0.6.5":"2025-10-09T15:31:45.100Z","0.6.3":"2025-10-09T15:48:03.610Z","0.6.2":"2025-10-09T17:03:15.580Z"},"bugs":{"url":"https://github.com/alti-js/nestjs-kafka/issues"},"author":{"name":"Angel Sanchez"},"license":"MIT","homepage":"https://github.com/alti-js/nestjs-kafka/#readme","keywords":["nestjs","kafkajs"],"repository":{"type":"git","url":"git+https://github.com/alti-js/nestjs-kafka.git"},"description":"KafkaJS integration with NestJS","maintainers":[{"name":"asanchez-altimetrik","email":"asanchez@altimetrik.com"},{"name":"ankitkapadia","email":"akapadia@altimetrik.com"},{"name":"landrukanis","email":"landrukanis@altimetrik.com"},{"name":"praveenalti","email":"psurendran@altimetrik.com"},{"name":"sguhaprasad","email":"sguhaprasad@altimetrik.com"}],"readme":"\n \n ![\"Nest](\"https://nestjs.com/img/logo-small.svg\")
\n \n \n ![\"KafkaJS](\"https://raw.githubusercontent.com/tulios/kafkajs/master/logo/v2/kafkajs_circle.svg\")
\n \n
\n\n# NestJS + KafkaJS\n\nIntegration of KafkaJS with NestJS to build event driven microservices.\n\n\n## Setup\n\nImport and add the `KafkaModule` to the imports array of the module for which you would like to use Kafka.\n\n### Synchronous Module Initialization\n\nRegister the `KafkaModule` synchronous with the `register()` method:\n\n```javascript\n@Module({\n imports: [\n KafkaModule.register([\n {\n name: 'HERO_SERVICE',\n options: {\n client: {\n clientId: 'hero',\n brokers: ['localhost:9092'],\n },\n consumer: {\n groupId: 'hero-consumer'\n }\n }\n },\n ]),\n ]\n ...\n})\n\n```\n\n### Asynchronous Module Initialization\n\nRegister the `KafkaModule` asynchronous with the `registerAsync()` method:\n\n```javascript\nimport { ConfigModule, ConfigService } from '@nestjs/config';\n\n@Module({\n imports: [\n ConfigModule.forRoot(),\n KafkaModule.registerAsync(['HERO_SERVICE'], {\n useFactory: async (configService: ConfigService) => {\n const broker = this.configService.get('broker');\n return [\n {\n name: 'HERO_SERVICE',\n options: {\n clientId: 'hero',\n brokers: [broker],\n },\n consumer: {\n groupId: 'hero-consumer'\n }\n }\n }\n ];\n },\n inject: [ConfigService]\n })\n ]\n ...\n})\n\n```\n\nFull settings can be found:\n\n| Config | Options |\n| ------ | ------- | \n| client | https://kafka.js.org/docs/configuration | \n| consumer | https://kafka.js.org/docs/consuming#options |\n| producer | https://kafka.js.org/docs/producing#options |\n| serializer | |\n| deserializer | |\n| consumeFromBeginning | true/false |\n| | |\n\n\n\n### Subscribing\n\nSubscribing to a topic to accept messages.\n\n```javascript\nexport class Consumer {\n constructor(\n @Inject('HERO_SERVICE') private client: KafkaService\n ) {}\n\n onModuleInit(): void {\n this.client.subscribeToResponseOf('hero.kill.dragon', this)\n }\n\n @SubscribeTo('hero.kill.dragon')\n async getWorld(data: any, key: any, offset: number, timestamp: number, partition: number, headers: IHeaders): Promise {\n ...\n }\n\n}\n\n```\n\n### Producing\n\nSend messages back to kafka.\n\n```javascript\nconst TOPIC_NAME = 'hero.kill.dragon';\n\nexport class Producer {\n constructor(\n @Inject('HERO_SERVICE') private client: KafkaService\n ) {}\n\n async post(message: string = 'Hello world'): Promise {\n const result = await this.client.send({\n topic: TOPIC_NAME,\n messages: [\n {\n key: '1',\n value: message\n }\n ]\n });\n\n return result;\n }\n\n}\n\n```\n\n### Schema Registry support.\n\nBy default messages are converted to JSON objects were possible. If you're using\nAVRO you can add the `SchemaRegistry` deserializer to convert the messages. This uses the [KafkaJS Schema-registry module](https://github.com/kafkajs/confluent-schema-registry)\n\nIn your `module.ts`:\n\n```javascript\n\n@Module({\n imports: [\n KafkaModule.register([\n {\n name: 'HERO_SERVICE',\n options: {\n client: {\n clientId: 'hero',\n brokers: ['localhost:9092'],\n },\n consumer: {\n groupId: 'hero-consumer'\n }\n },\n deserializer: new KafkaAvroResponseDeserializer({\n host: 'http://localhost:8081'\n }),\n serializer: new KafkaAvroRequestSerializer({\n config: {\n host: 'http://localhost:8081/'\n },\n schemas: [\n {\n topic: 'test.topic',\n key: join(__dirname, 'key-schema.avsc'),\n value: join(__dirname, 'value-schema.avsc')\n }\n ],\n }),\n },\n ]),\n ]\n ...\n})\n```","readmeFilename":"README.md"}