{"_id":"@vvtri/nestjs-kafka","_rev":"30-5072be50246720cda2df6c740cdd11e0","time":{"created":"2022-10-13T06:43:28.450Z","1.0.0":"2022-10-09T08:22:51.049Z","modified":"2023-06-07T01:23:57.096Z","1.0.1":"2022-10-09T08:43:44.049Z","1.0.3":"2022-10-09T08:53:06.630Z","1.0.4":"2022-10-09T08:55:04.616Z","1.0.5":"2022-10-09T09:00:37.180Z","1.0.6":"2022-10-09T09:04:14.547Z","1.0.7":"2022-10-09T09:04:51.122Z","0.0.1":"2022-10-10T14:57:59.415Z","1.1.2":"2022-10-13T05:47:36.675Z","0.0.0":"2022-10-13T05:56:42.596Z","0.0.2":"2022-10-13T06:02:31.229Z","0.1.2":"2022-10-13T06:41:46.113Z","1.0.2":"2022-10-13T06:43:28.683Z","1.1.0":"2022-10-13T07:36:23.290Z","1.1.1":"2022-10-13T07:58:44.361Z","1.1.3":"2022-10-15T03:19:18.477Z","1.1.4":"2023-05-07T10:38:41.992Z","1.1.5":"2023-06-07T01:23:56.955Z"},"name":"@vvtri/nestjs-kafka","dist-tags":{"latest":"1.1.5"},"versions":{"1.0.2":{"name":"@vvtri/nestjs-kafka","version":"1.0.2","description":"A NestJS - KafkaJs Wrapper, wrapping on [KafkaJS](https://github.com/tulios/kafkajs)","main":"dist/src/index.js","repository":{"type":"git","url":"git+https://github.com/vvtri/nestjs-kafka.git"},"keywords":["nest","nestjs","kafka","nestjs-kafka"],"types":"dist/src/index.d.ts","publishConfig":{"access":"public"},"peerDependencies":{"@nestjs/common":"^9.0.0","@nestjs/core":"^9.0.0"},"peerDependenciesMeta":{"@nestjs/microservices":{"optional":true},"@nestjs/platform-express":{"optional":true}},"scripts":{"build":"tsc","test":"jest --config ./test/jest.config.json","start":"nest start -c ./test/mock/nest-cli.json --watch"},"author":{"name":"Trí Võ","email":"vtri2016@gmail.com","url":"https://github.com/vvtri/"},"license":"ISC","dependencies":{"@kafkajs/confluent-schema-registry":"^3.3.0","kafkajs":"^2.2.0","reflect-metadata":"^0.1.13"},"devDependencies":{"@babel/preset-typescript":"^7.18.6","@jest/globals":"^29.1.2","@nestjs/common":"^9.1.4","@nestjs/core":"^9.1.4","@nestjs/platform-express":"^9.1.4","@nestjs/testing":"^9.1.4","@types/supertest":"^2.0.12","jest":"^29.1.2","prettier":"^2.7.1","rimraf":"^3.0.2","rxjs":"^7.5.7","supertest":"^6.3.0","ts-jest":"^29.0.3","typescript":"^4.8.4"},"engines":{"node":">= 12.9.0"},"gitHead":"dd86945ad7afaa39bc429dcdd146b07347e66b2b","bugs":{"url":"https://github.com/vvtri/nestjs-kafka/issues"},"homepage":"https://github.com/vvtri/nestjs-kafka#readme","_id":"@vvtri/nestjs-kafka@1.0.2","_nodeVersion":"16.14.0","_npmVersion":"8.5.2","dist":{"integrity":"sha512-MUrpnrjZuumVOseny6Y+E/kWscz31C03PPj9qseh9PgcDHIttrQGSXLm0effZPPnzaENvR7/BzzcuUgs4QC2HQ==","shasum":"e9ca1374dbe894b052a931f7b955391c5846ab14","tarball":"https://registry.npmjs.org/@vvtri/nestjs-kafka/-/nestjs-kafka-1.0.2.tgz","fileCount":36,"unpackedSize":22025,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDGAsFVAKIFWqypx+1yH/v0qwLKPjYdnnEcPivJUIfgSQIgWjBoL7bMQSEc0N35iqhL4lUG5YHPZJbS+sWhfGXzMBU="}],"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v4.10.10\r\nComment: https://openpgpjs.org\r\n\r\nwsFzBAEBCAAGBQJjR7OQACEJED1NWxICdlZqFiEECWMYAoorWMhJKdjhPU1b\r\nEgJ2Vmr2/w/7BBddK5xeUqrhviENpDYjSLHlJqQOIF8bXCgOaRcQEZuzZQYF\r\nbX+wlJZOP4FVpcyVM0GTR0aprTwCFWlXMJ2D4z+hLis909SM/TW4QKldOlxJ\r\n4O2vX4sfZ0ExEQ5X0u7I5GHuDqGu9ZbLYViFM0hdEwWtfxZrnFzuakiMxixC\r\n1eaqj6QuBLVRi/4GHlR6xxu/ZSzbaw8maigIttEnN/hNLwCliF5H+Srg6L55\r\nqu/P71T349J0QVe5nYySJ3LKqa7jn9PzH8BUXWEmD3BvxV5QVQDmYboOfs/T\r\nA45Ru31AYjBOE6HaGbKXzH5rAHuZVY578wEdWIyMRV4TCwzAvOqpDeW0HDG2\r\nNh97i4dyCiHJFMRNpsuyuF40lfq6JHmfcBmxePYWs9eEV4HItZHIJdg9K/cQ\r\nF0wFtC9fzQ8RxpZMfmNDp2/PvbAq2Ao0fLqPYrQi/+8kB0e9/HSbNtwV76QW\r\nK5RIbXi+XDpn6JqKAIqp0MYCIEFJgOPTNy/7+lztzxjwilR18nmgOlc+iRfN\r\nEkoPcr3KHnjESMUjH1R7IiL1G82DxIzjzBmr+nHB+95LvGB80CyACX2TV4NT\r\nbMCjrpHOwFIFzXqsQsRWahZ0h0RIoL3iwYxLPGNeK6oIqCxrNw+iS0pyvuhi\r\ngA5HskDP5u2ZpK42UAS2yAztCZjRaNJMqh4=\r\n=xHpv\r\n-----END PGP SIGNATURE-----\r\n"},"_npmUser":{"name":"vvtri","email":"vtri2016@gmail.com"},"directories":{},"maintainers":[{"name":"vvtri","email":"vtri2016@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/nestjs-kafka_1.0.2_1665643408526_0.4703687602240161"},"_hasShrinkwrap":false},"1.1.0":{"name":"@vvtri/nestjs-kafka","version":"1.1.0","description":"### Description","main":"dist/src/index.js","repository":{"type":"git","url":"git+https://github.com/vvtri/nestjs-kafka.git"},"keywords":["nest","nestjs","kafka","nestjs-kafka"],"types":"dist/src/index.d.ts","publishConfig":{"access":"public"},"peerDependencies":{"@nestjs/common":"^9.0.0","@nestjs/core":"^9.0.0"},"peerDependenciesMeta":{"@nestjs/microservices":{"optional":true},"@nestjs/platform-express":{"optional":true}},"scripts":{"build":"tsc","test":"jest --config ./test/jest.config.json","start":"nest start -c ./test/mock/nest-cli.json --watch"},"author":{"name":"Trí Võ","email":"vtri2016@gmail.com","url":"https://github.com/vvtri/"},"license":"ISC","dependencies":{"@kafkajs/confluent-schema-registry":"^3.3.0","kafkajs":"^2.2.0","reflect-metadata":"^0.1.13"},"devDependencies":{"@babel/preset-typescript":"^7.18.6","@jest/globals":"^29.1.2","@nestjs/common":"^9.1.4","@nestjs/core":"^9.1.4","@nestjs/platform-express":"^9.1.4","@nestjs/testing":"^9.1.4","@types/supertest":"^2.0.12","jest":"^29.1.2","prettier":"^2.7.1","rimraf":"^3.0.2","rxjs":"^7.5.7","supertest":"^6.3.0","ts-jest":"^29.0.3","typescript":"^4.8.4"},"engines":{"node":">= 12.9.0"},"gitHead":"104b1509cf88693eddc314b16ec45743be4dbda0","bugs":{"url":"https://github.com/vvtri/nestjs-kafka/issues"},"homepage":"https://github.com/vvtri/nestjs-kafka#readme","_id":"@vvtri/nestjs-kafka@1.1.0","_nodeVersion":"16.17.1","_npmVersion":"8.15.0","dist":{"integrity":"sha512-8FQOX1jaPceVFH+ilHXFjNZ6WBRwItIIgBqoXwD2KbKJiHJ9jpJiRqKq9sM09NKXfacgJwxbCMG2IlAJ716O9g==","shasum":"7709b5fedb022c655ec86411d559278729259b70","tarball":"https://registry.npmjs.org/@vvtri/nestjs-kafka/-/nestjs-kafka-1.1.0.tgz","fileCount":30,"unpackedSize":22358,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIHTHFMUkKSsDmvqxM1a/39BwFiXJpYdH2fp8vTybCHUvAiEAo1Gr2lLiRmrrZ+C8W27zk2kMLWJ9l4kmzMfgGT+dRDM="}],"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v4.10.10\r\nComment: https://openpgpjs.org\r\n\r\nwsFzBAEBCAAGBQJjR7/3ACEJED1NWxICdlZqFiEECWMYAoorWMhJKdjhPU1b\r\nEgJ2VmoWZhAAoBC0Zmdi7T0r6Sk7YxhIwq0rfvlxpZk22FOeCYH51Bl+1y/d\r\nyj97aVM1GEoWrzCCJJzRI3yYD+IyGjD+0pLCx/w6q84HmjjQMb35yTkAwCw+\r\nLDSCYMGr+5gLeWKmOHF8kfn68IUsmejW3SzSwBsfqIrxN2nNPzkg/f4Pnv3n\r\nQQnJlIQNm4sDFFltC/r7iazFqZyqrUJ4apzVFlxx9M/p20sIdgem5aL5lL7W\r\nkiONbN4UpceQsoAGaWf6pMiOygYQWC0pJZkhtyVsmjegygieCvtLfZ7GX+7r\r\npAb5VPNyjnrxeQy6YWE2nU4rQ1Ta+afLTbFxFZb0ur9oyP2gX2+RnfPX9hi8\r\nYpQwvbJA6UhLW0bNHUlWYkzkTpwi5Sk6eY3n50mtvi5GeL90qIjEceB6gfJL\r\n3EK0QeHvUWdtHe9+im91rWEk2mUlvzNIkOFJxnSmz9pu37V6QUBF5NobWlN1\r\n7GkTBnoTAT3z1Z8tShcCRQN5yr07eCj3ey9kizaoAepuR6v3x186iZh3GFLF\r\nmdWSZ/btJUNPKBDli41KT0JjAwBxBP5jJT/OI/d1IqGiAKF5LIpMTsObJ7Ao\r\nWvAok0vO20B32tOj60v4OAa/6YjE9itKXOxFeEHePVzdk/aFGzRPftAJUoxP\r\n8sPloSX0X8kVYYWkHh+HkullGFhYKUiPDx8=\r\n=uRrd\r\n-----END PGP SIGNATURE-----\r\n"},"_npmUser":{"name":"vvtri","email":"vtri2016@gmail.com"},"directories":{},"maintainers":[{"name":"vvtri","email":"vtri2016@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/nestjs-kafka_1.1.0_1665646583145_0.03873282866700789"},"_hasShrinkwrap":false},"1.1.1":{"name":"@vvtri/nestjs-kafka","version":"1.1.1","description":"### Description","main":"dist/src/index.js","repository":{"type":"git","url":"git+https://github.com/vvtri/nestjs-kafka.git"},"keywords":["nest","nestjs","kafka","nestjs-kafka"],"types":"dist/src/index.d.ts","publishConfig":{"access":"public"},"peerDependencies":{"@nestjs/common":"^9.0.0","@nestjs/core":"^9.0.0"},"peerDependenciesMeta":{"@nestjs/microservices":{"optional":true},"@nestjs/platform-express":{"optional":true}},"scripts":{"build":"tsc","test":"jest --config ./test/jest.config.json","start":"nest start -c ./test/mock/nest-cli.json --watch"},"author":{"name":"Trí Võ","email":"vtri2016@gmail.com","url":"https://github.com/vvtri/"},"license":"ISC","dependencies":{"@kafkajs/confluent-schema-registry":"^3.3.0","kafkajs":"^2.2.0","reflect-metadata":"^0.1.13"},"devDependencies":{"@babel/preset-typescript":"^7.18.6","@jest/globals":"^29.1.2","@nestjs/common":"^9.1.4","@nestjs/core":"^9.1.4","@nestjs/platform-express":"^9.1.4","@nestjs/testing":"^9.1.4","@types/supertest":"^2.0.12","jest":"^29.1.2","prettier":"^2.7.1","rimraf":"^3.0.2","rxjs":"^7.5.7","supertest":"^6.3.0","ts-jest":"^29.0.3","typescript":"^4.8.4"},"engines":{"node":">= 12.9.0"},"gitHead":"46a3acf861b7cb47961de3121845a45fd2b67b5e","bugs":{"url":"https://github.com/vvtri/nestjs-kafka/issues"},"homepage":"https://github.com/vvtri/nestjs-kafka#readme","_id":"@vvtri/nestjs-kafka@1.1.1","_nodeVersion":"16.17.1","_npmVersion":"8.15.0","dist":{"integrity":"sha512-0qBeVK40A2+BwHWjwLHdKUUHdGCO7geve7nKrFt8sulZaI9NAgFaPnL0JltavB7NKKzycHh6DDKP//b6NeSFiQ==","shasum":"b55b6c7c683ee59cd653383c0868b4059c0d7a2a","tarball":"https://registry.npmjs.org/@vvtri/nestjs-kafka/-/nestjs-kafka-1.1.1.tgz","fileCount":30,"unpackedSize":22374,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCICuoujQSSESTX4uFpdbmRd1eBmJhyUpExfwqMTy+/oizAiEAwtA7LoiBNVZa5aJiBWUpuEUb9yDvLn9PHs5O5MlvtUI="}],"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v4.10.10\r\nComment: https://openpgpjs.org\r\n\r\nwsFzBAEBCAAGBQJjR8U0ACEJED1NWxICdlZqFiEECWMYAoorWMhJKdjhPU1b\r\nEgJ2VmqiYRAAiFDNinb1QrepOcGg8jqXjTDdqR+f0wMu0c46yInWFAt0DTAI\r\nNVTg9O9Gtid91KXOwbAu1wsXQ+iNkMZRzsoWOZ8Snhxi2xDcToZs/uSEM29w\r\nC2GbB4sFruE5aQflgdM1OXoQpdGZcrRompNmbNnQwp8BolcyEqYzaKvao04B\r\nuQOkmf7iOVIXvrwDY56G5YEPrpFqOL51urQwIvCTHJu0q6xz9Z4sNUKQreuD\r\njM4xVBXOSdug9oSSpKxw3kr7JZYH6idU9gwkEI+advhTBZhwCiR50/MFH+x/\r\nZDxex0by/7Pgn4JqVIfXdiNPBMfnQ+ZZ+XY/n6D3G/nSMV66C5ONdzahV+pn\r\nugWJFS1SG32fay9Mc2nhcAGfV9V1t/IBk3xl8C5FgbJmhmTTgwsoEP4K04h0\r\nlsl/wtEClVcDEGwtIMmonSmPN9hov9JqX9YzruY+YVGo3jizPh1i5BpDhX+4\r\n5epqu7hSmjyRenzF00YUV2pY1xAsuCWMuxBhm4cRKO/t5bSeFUXNDc+S4wX4\r\n6kgj+L9meWmINm0wO9U1DAKpiQpdpnLiGCCZCL0oyGVWA5wCIlmv4Md3aGOR\r\nPhc/P+0bXGZQLD70i09hLKGqt+YaaJWaKGKgnkvLztFlXYwTU/u/7R5iVkiK\r\nIDIAPT2MDB3pr+lrpFeYJi1rc3AF1itQseY=\r\n=QdWg\r\n-----END PGP SIGNATURE-----\r\n"},"_npmUser":{"name":"vvtri","email":"vtri2016@gmail.com"},"directories":{},"maintainers":[{"name":"vvtri","email":"vtri2016@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/nestjs-kafka_1.1.1_1665647924186_0.275749187946857"},"_hasShrinkwrap":false},"1.1.3":{"name":"@vvtri/nestjs-kafka","version":"1.1.3","description":"### Description","main":"dist/src/index.js","repository":{"type":"git","url":"git+https://github.com/vvtri/nestjs-kafka.git"},"keywords":["nest","nestjs","kafka","nestjs-kafka"],"types":"dist/src/index.d.ts","publishConfig":{"access":"public"},"peerDependencies":{"@nestjs/common":"^9.0.0","@nestjs/core":"^9.0.0"},"peerDependenciesMeta":{"@nestjs/microservices":{"optional":true},"@nestjs/platform-express":{"optional":true}},"scripts":{"build":"tsc","test":"jest --config ./test/jest.config.json","start":"nest start -c ./test/mock/nest-cli.json --watch"},"author":{"name":"Trí Võ","email":"vtri2016@gmail.com","url":"https://github.com/vvtri/"},"license":"ISC","dependencies":{"@kafkajs/confluent-schema-registry":"^3.3.0","kafkajs":"^2.2.0","reflect-metadata":"^0.1.13"},"devDependencies":{"@babel/preset-typescript":"^7.18.6","@jest/globals":"^29.1.2","@nestjs/common":"^9.1.4","@nestjs/core":"^9.1.4","@nestjs/platform-express":"^9.1.4","@nestjs/testing":"^9.1.4","@types/supertest":"^2.0.12","jest":"^29.1.2","prettier":"^2.7.1","rimraf":"^3.0.2","rxjs":"^7.5.7","supertest":"^6.3.0","ts-jest":"^29.0.3","typescript":"^4.8.4"},"engines":{"node":">= 12.9.0"},"gitHead":"1576935c7540b26c557a95bde1687f085222d6ac","bugs":{"url":"https://github.com/vvtri/nestjs-kafka/issues"},"homepage":"https://github.com/vvtri/nestjs-kafka#readme","_id":"@vvtri/nestjs-kafka@1.1.3","_nodeVersion":"16.17.1","_npmVersion":"8.15.0","dist":{"integrity":"sha512-E6Gefyb4bK9V3faSD47jYxEfX0zTryuxzfTJ+YecJYMisNo222UkoefHaKYJ6uferr/kpdBD3h6rOrsE0YW1BA==","shasum":"b7580e94c1d6ecd77374c0c60c3652ebd3f7a603","tarball":"https://registry.npmjs.org/@vvtri/nestjs-kafka/-/nestjs-kafka-1.1.3.tgz","fileCount":30,"unpackedSize":22343,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIACg4RuS9rcA7L0dxu4TrhaPZMDC/pQN1NEzeMs3mP5YAiEAzGPF3rQQYNa3CIwhzLUthIKToETKIGA5whGowK1sWYM="}],"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v4.10.10\r\nComment: https://openpgpjs.org\r\n\r\nwsFzBAEBCAAGBQJjSia2ACEJED1NWxICdlZqFiEECWMYAoorWMhJKdjhPU1b\r\nEgJ2Vmo/yg/+Ng8nincV/6E8T/6CPfFtH4G/AwWiyKH5+L0HrRp0d86gjm9A\r\nWLlJctMMZqhC/a9rlPCN7UYSSz2pnskV84KhbOxN2mBLBwPHtiyTX6cLayRi\r\nXh02brIqxFnqAkahi7ufxIxPwP7DR8yzYx8lkQynqXFZzvX2tuITnU4+W6S1\r\n8kmeU2Y39YwB445IMjfrX+611KsqugvOm3RlfWoBfYCahd2biE9VhVO9ejOX\r\nGxPdugewzSL0CrhLH3CvwfzEZ1X3Jcy9tNjBzArS+8ZAV0KGM2iSst2h/SqO\r\ncGjw5XDLfrF8vFnNR6bXlVu4Yw3mtIUFIUtQxFmNHmg6kW5BpWJubsRm7Io6\r\nsmEZFM5/uF65P3fETIXKWkZC4pOwq/us8HlUzZo2nVDtug0zmqObcW2sYkMP\r\nLTgcYky5LixLpgWcq5YB5whG6+GitWWtmqw7eSQtRE+QiMkZHtbmL8uxpWcc\r\n07ZiC8xLi1RxTPGkvUtb3vWuPEjeqy3JaOg9XryYClkce5+wIbKrH5dQL7rU\r\nEIjbemetSOe+7w/G01VzoF7cXlpeVBM/Ciwi4hj7eFDJ3E1yLWo//jj4SWHQ\r\nxme5FgJC1E4K+FCZOcdMFB5TFUUsn+QQv2vgnSSCcyJQn9DHzBrp0SjCz1SS\r\njeK6RP2HSYqlVYZm7FIAtRyF8EZTEUYX7bo=\r\n=OGjn\r\n-----END PGP SIGNATURE-----\r\n"},"_npmUser":{"name":"vvtri","email":"vtri2016@gmail.com"},"directories":{},"maintainers":[{"name":"vvtri","email":"vtri2016@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/nestjs-kafka_1.1.3_1665803958301_0.01987786541066705"},"_hasShrinkwrap":false},"1.1.4":{"name":"@vvtri/nestjs-kafka","version":"1.1.4","description":"A NestJS - KafkaJs Wrapper, wrapping on [KafkaJS](https://github.com/tulios/kafkajs)","main":"dist/src/index.js","repository":{"type":"git","url":"git+https://github.com/vvtri/nestjs-kafka.git"},"keywords":["nest","nestjs","kafka","nestjs-kafka"],"types":"dist/src/index.d.ts","publishConfig":{"access":"public"},"peerDependencies":{"@nestjs/common":"^9.0.0","@nestjs/core":"^9.0.0"},"peerDependenciesMeta":{"@nestjs/microservices":{"optional":true},"@nestjs/platform-express":{"optional":true}},"scripts":{"build":"tsc","test":"jest --config ./test/jest.config.json","start":"nest start -c ./test/mock/nest-cli.json --watch"},"author":{"name":"Trí Võ","email":"vtri2016@gmail.com","url":"https://github.com/vvtri/"},"license":"ISC","dependencies":{"@kafkajs/confluent-schema-registry":"3.3.0","kafkajs":"2.2.0","reflect-metadata":"0.1.13"},"devDependencies":{"@babel/preset-typescript":"7.18.6","@jest/globals":"29.1.2","@nestjs/common":"9.1.4","@nestjs/core":"9.1.4","@nestjs/platform-express":"9.1.4","@nestjs/testing":"9.1.4","@types/supertest":"2.0.12","@typescript-eslint/eslint-plugin":"5.59.2","@typescript-eslint/parser":"5.59.2","eslint":"8.40.0","eslint-config-prettier":"8.8.0","eslint-plugin-prettier":"4.2.1","husky":"8.0.3","jest":"29.1.2","lint-staged":"13.2.2","prettier":"2.8.8","rimraf":"3.0.2","rxjs":"7.5.7","supertest":"6.3.0","ts-jest":"29.0.3","typescript":"4.8.4"},"engines":{"node":">= 12.9.0"},"gitHead":"a9dbe779c2771a0d9a7e2761733c3bee27a27c32","bugs":{"url":"https://github.com/vvtri/nestjs-kafka/issues"},"homepage":"https://github.com/vvtri/nestjs-kafka#readme","_id":"@vvtri/nestjs-kafka@1.1.4","_nodeVersion":"16.20.0","_npmVersion":"8.19.4","dist":{"integrity":"sha512-BGpnJ/NNYOZEtNUq4pWrVVptufWrKXZ6+zMuPeyfQRrotrFouEJKc3PvbhaaWObbipC/Ib+MpWhIGzMxwkPqrA==","shasum":"b5a910b3e0bd2f5388553a55e2a117427856d599","tarball":"https://registry.npmjs.org/@vvtri/nestjs-kafka/-/nestjs-kafka-1.1.4.tgz","fileCount":30,"unpackedSize":22920,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIG8z86UjYCn48kx3T4XyIczpR/a0sy919jB52eLe325AAiBnPFa+vqzsAPQWoSWBC3VcfIJg9Je4HXdUi4XiU5DPig=="}]},"_npmUser":{"name":"vvtri","email":"vtri2016@gmail.com"},"directories":{},"maintainers":[{"name":"vvtri","email":"vtri2016@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/nestjs-kafka_1.1.4_1683455921823_0.7500918175638993"},"_hasShrinkwrap":false},"1.1.5":{"name":"@vvtri/nestjs-kafka","version":"1.1.5","description":"A NestJS - KafkaJs Wrapper, wrapping on [KafkaJS](https://github.com/tulios/kafkajs)","main":"dist/src/index.js","repository":{"type":"git","url":"git+https://github.com/vvtri/nestjs-kafka.git"},"keywords":["nest","nestjs","kafka","nestjs-kafka"],"types":"dist/src/index.d.ts","publishConfig":{"access":"public"},"peerDependencies":{"@nestjs/common":"^9.0.0","@nestjs/core":"^9.0.0"},"peerDependenciesMeta":{"@nestjs/microservices":{"optional":true},"@nestjs/platform-express":{"optional":true}},"scripts":{"build":"tsc","test":"jest --config ./test/jest.config.json","start":"nest start -c ./test/mock/nest-cli.json --watch"},"author":{"name":"Trí Võ","email":"vtri2016@gmail.com","url":"https://github.com/vvtri/"},"license":"ISC","dependencies":{"@kafkajs/confluent-schema-registry":"3.3.0","kafkajs":"2.2.0","reflect-metadata":"0.1.13"},"devDependencies":{"@babel/preset-typescript":"7.18.6","@jest/globals":"29.1.2","@nestjs/common":"9.1.4","@nestjs/core":"9.1.4","@nestjs/platform-express":"9.1.4","@nestjs/testing":"9.1.4","@types/supertest":"2.0.12","@typescript-eslint/eslint-plugin":"5.59.2","@typescript-eslint/parser":"5.59.2","eslint":"8.40.0","eslint-config-prettier":"8.8.0","eslint-plugin-prettier":"4.2.1","husky":"8.0.3","jest":"29.1.2","lint-staged":"13.2.2","prettier":"2.8.8","rimraf":"3.0.2","rxjs":"7.5.7","supertest":"6.3.0","ts-jest":"29.0.3","typescript":"4.8.4"},"engines":{"node":">= 12.9.0"},"gitHead":"fbb28a5f2c7defb6e2e250893e850557b3ac5f9b","bugs":{"url":"https://github.com/vvtri/nestjs-kafka/issues"},"homepage":"https://github.com/vvtri/nestjs-kafka#readme","_id":"@vvtri/nestjs-kafka@1.1.5","_nodeVersion":"16.20.0","_npmVersion":"8.19.4","dist":{"integrity":"sha512-g3PzsKpgFzXmy53l4wLItvV2ybZ2JVuB2B7YwDAQgug9KFOnFUA85A7RdgRnz+McxAecKc6ucjvzCyW/d044kw==","shasum":"4b1967770019bddef9e018c30e4aec2fa8284e20","tarball":"https://registry.npmjs.org/@vvtri/nestjs-kafka/-/nestjs-kafka-1.1.5.tgz","fileCount":30,"unpackedSize":24004,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIBQoSV5EqPFn/rgvSSi6u0KCmSOUt0uReRJNhF1JGDAIAiBbu0vrZmG2byzcc7Lm+Z4BSOnquUyPowZ5I2mIMLndAQ=="}]},"_npmUser":{"name":"vvtri","email":"vtri2016@gmail.com"},"directories":{},"maintainers":[{"name":"vvtri","email":"vtri2016@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/nestjs-kafka_1.1.5_1686101036788_0.39833316463702584"},"_hasShrinkwrap":false}},"maintainers":[{"name":"vvtri","email":"vtri2016@gmail.com"}],"description":"A NestJS - KafkaJs Wrapper, wrapping on [KafkaJS](https://github.com/tulios/kafkajs)","homepage":"https://github.com/vvtri/nestjs-kafka#readme","keywords":["nest","nestjs","kafka","nestjs-kafka"],"repository":{"type":"git","url":"git+https://github.com/vvtri/nestjs-kafka.git"},"author":{"name":"Trí Võ","email":"vtri2016@gmail.com","url":"https://github.com/vvtri/"},"bugs":{"url":"https://github.com/vvtri/nestjs-kafka/issues"},"license":"ISC","readme":"## NestJs Kafka Client\r\n\r\n### Description\r\n\r\nA NestJS - KafkaJs Wrapper, wrapping on [KafkaJS](https://github.com/tulios/kafkajs)\r\n\r\n### Installation\r\n\r\n```bash\r\nnpm install @vvtri/nestjs-kafka\r\n```\r\nor yarn:\r\n```bash\r\nyarn add @vvtri/nestjs-kafka\r\n```\r\n\r\n### Add it to the NestJS app.module.ts\r\n\r\n```ts\r\nimport { KafkaModule, ConsumerConfig, KafkaConfig, KafkaModuleConfig } from '@vvtri/nestjs-kafka';\r\n\r\n\r\nconst kafkaConfig: KafkaConfig = {\r\n  clientId: 'my-app',\r\n  brokers: ['localhost:9092'],\r\n  ssl: false,\r\n  connectionTimeout: 99999,\r\n};\r\n\r\nconst consumerConfig: ConsumerConfig = {\r\n  groupId: 'test',\r\n  allowAutoTopicCreation: true,\r\n};\r\n\r\n@Module({\r\n  imports: [KafkaModule.forRoot({ kafkaConfig, consumerConfig })],\r\n  controllers: [],\r\n  providers: [],\r\n})\r\nexport class AppModule {}\r\n```\r\n\r\nTo see all available config, see `KafkaModuleConfig.`\r\n\r\n### How to sendMessage\r\n\r\n```ts\r\nimport {  KafkaProducer } from '@vvtri/nestjs-kafka';\r\n\r\n@Injectable()\r\nexport class TaskKafkaProductService {\r\n  constructor(private readonly kafkaProducer: KafkaProducer,) {}\r\n\r\n  public async sendPushTask(kafkaTaskDto: KafkaTaskDto): Promise<any> {\r\n     await this.kafkaProducer.send<KafkaTaskDto>(\r\n      {\r\n        topic: Topic,\r\n        messages: [{ value: kafkaTaskDto }],\r\n      },\r\n      {\r\n        autoStringifyJson: true,\r\n      }\r\n    );\r\n  }\r\n}\r\n```\r\n\r\n### How to Subscribe Message\r\n\r\n```ts\r\nimport { EachMessagePayload, KafkaListener, SubscribeTo } from '@vvtri/nestjs-kafka';\r\n\r\n@Injectable()\r\n@KafkaListener()\r\nexport class TaskKafkaConsumerService {\r\n  @SubscribeTo('task.push.info', { autoParseByJson: true //default true})\r\n  taskSubscriber(payload: EachMessagePayload<string>): any {\r\n    console.log('value', payload.message.value)\r\n    console.log('header', payload.message.headers)\r\n    console.log('key', payload.message.key)\r\n  }\r\n}\r\n```\r\n","readmeFilename":"README.md"}