{"_id":"@akenzy/kafka","_rev":"3-3e9c4051fb5cfc834cba8427bcd25b06","name":"@akenzy/kafka","dist-tags":{"latest":"0.0.4"},"versions":{"0.0.1":{"name":"@akenzy/kafka","version":"0.0.1","main":"dist/index.js","types":"dist/index.d.ts","license":"ISC","description":"Kafka module for NestJS","directories":{"lib":"dist"},"repository":{"type":"gitlab","url":"git+https://gitlab.com/akenzy/kenzy-kafka-module.git"},"type":"commonjs","author":{"name":"lamhoangancmvn","email":"lamhan3012@gmail.com"},"scripts":{"build":"tsc -p tsconfig.build.json","prepublishOnly":"yarn build"},"dependencies":{"@nestjs/common":"^9.0.0","@nestjs/core":"^9.0.0","kafkajs":"^2.2.3","rxjs":"^7.2.0"},"devDependencies":{"typescript":"^4.7.4"},"gitHead":"25bb5209f47a97cdf688dea32971c4f007640e87","bugs":{"url":"https://gitlab.com/akenzy/kenzy-kafka-module/issues"},"homepage":"https://gitlab.com/akenzy/kenzy-kafka-module#readme","_id":"@akenzy/kafka@0.0.1","_nodeVersion":"16.17.0","_npmVersion":"9.3.0","dist":{"integrity":"sha512-Vrd5YFPwd5Ah9wanGGzqyxqj0mzaEOxWmJs/IknZ2fpGLq3aajcDgcwJLIYA177NvCA9x+LZ7H6WPwTviFuKjg==","shasum":"44a89690013b0e45fb8849b7d465ff1c9c101b25","tarball":"https://registry.npmjs.org/@akenzy/kafka/-/kafka-0.0.1.tgz","fileCount":44,"unpackedSize":125772,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIGJiHAvDB7T0erC74ujk+UC0aYleHwQ4TgAPfzMEw2stAiAn9cM4NSL6aa1Yh1bhdTxX49BYX0heYOoVRVOeubnGdw=="}],"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v4.10.10\r\nComment: https://openpgpjs.org\r\n\r\nwsFzBAEBCAAGBQJjxNrvACEJED1NWxICdlZqFiEECWMYAoorWMhJKdjhPU1b\r\nEgJ2VmqdSBAAkREHPn90gbHhgcQ7p8rVRokyPfXSliQtCvhZdaiSTG7X4Y1o\r\n8ExLjW0zJRvD9iDp2InJxOKzRb64eureJ5fFrkf4g9nYJXt+YW3wwOhb6StZ\r\nNvepn0Ycq+xlt0TzsjJa45H7poeHLu30xtntfE7y296mqO4bgOIWOREBMSaj\r\neJTqG05pQz/ALIVmuKNXmKk5TsW2YNCGX9gsnpBldaYYUjuQOcWbqxZDbL6W\r\nLhTjf/hMfaj9JrOXMeo2slh0oaHvEfg9mqnihpW30G7RPfTbIGwG4UfkFWJB\r\nFPQZnqPEs0gHJ5dC8ueSUfiPJ6Bwb2sVlqPOBbbbNAeHrFVGKAnKyEyw8CH6\r\nZNv8mMXNurgeDkQcSN8uUPNjzmgFLKbhSVS/eZNLeQII7/Y2YtT9N0ACsKiG\r\ntu77YYazMb7Jnr+zZCuxfC2XUCL4O50hOxCiKUlfdjCAGVsgs8QwWEI9sbEw\r\nFGOMLLU2mjBWWigIzzZU4f7OgzqX822ddKvlPFuBVv6SNCB/5xU9Jii+2Bp0\r\n8PL9KKN7e3ogKO2fEkyLfkJOSv3S8/jsxfPev0buyZ4viPJGXjClxzRslrRF\r\nOmuW6+0mGZaQmWGeV+jHY1xlnYBiEl1Vo2oyysM5xda8HHkfDWVOGn+XEu2l\r\ndZ2+wo+UtJ5IaQ1whFJ5tv5x/L66PjVcDik=\r\n=QGu7\r\n-----END PGP SIGNATURE-----\r\n"},"_npmUser":{"name":"akenzy","email":"lamhan3012@gmail.com"},"maintainers":[{"name":"akenzy","email":"lamhan3012@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka_0.0.1_1673845487664_0.5756237687337249"},"_hasShrinkwrap":false},"0.0.2":{"name":"@akenzy/kafka","version":"0.0.2","main":"dist/index.js","types":"dist/index.d.ts","license":"ISC","description":"Kafka module for NestJS","directories":{"lib":"dist"},"repository":{"type":"gitlab","url":"git+https://gitlab.com/akenzy/kenzy-kafka-module.git"},"type":"commonjs","author":{"name":"lamhoangancmvn","email":"lamhan3012@gmail.com"},"scripts":{"build":"tsc -p tsconfig.build.json","prepublishOnly":"yarn build"},"dependencies":{"@nestjs/common":"^9.0.0","@nestjs/core":"^9.0.0","kafkajs":"^2.2.3","rxjs":"^7.2.0"},"devDependencies":{"typescript":"^4.7.4"},"gitHead":"bd4eeb19b61c91add38371ef9f16b0bd4b2012b9","bugs":{"url":"https://gitlab.com/akenzy/kenzy-kafka-module/issues"},"homepage":"https://gitlab.com/akenzy/kenzy-kafka-module#readme","_id":"@akenzy/kafka@0.0.2","_nodeVersion":"16.17.0","_npmVersion":"9.3.0","dist":{"integrity":"sha512-1Z5lxZGlQYzFYTKB4VDFEgn9XJ4MjC4ioUR0wBReEZ5C6c0ZsjgRN7ncKelxC8DMbzoIkHuh1EFZ02vK6hA+ZQ==","shasum":"54dec3f8477a765c6e72e574ca965cdb52477514","tarball":"https://registry.npmjs.org/@akenzy/kafka/-/kafka-0.0.2.tgz","fileCount":45,"unpackedSize":127900,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDbTndfxjz36ksehw/Zcjq61kC8bPHIJFbvS5r5zqcwRwIgY3R4/K2yTdX5MXAZMFcU91VIqH4t8v3McmB5dEMkaX4="}],"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v4.10.10\r\nComment: https://openpgpjs.org\r\n\r\nwsFzBAEBCAAGBQJjxO5HACEJED1NWxICdlZqFiEECWMYAoorWMhJKdjhPU1b\r\nEgJ2Vmr4Cw/8DgUxjl4HRqcjnQqjwMpn1plYbsw5POvWin/agEzQhSWpjgwq\r\nPL4Zlb29HmXjrS6b+4LW48h9v8cuCCA0R0lgRtYFllrkW7BrOeK+lDS6lBg/\r\n14spD7+qTyKILbLqEKNUi2o6q0qEG+EJZV3wHjhz0pGhHvrEk4KDi3wfHYAP\r\n12ZeXnr7KpCQMKM/YItCr4xCe/F9GqTkEo4PCZ5hJOZOpFYOx6ahYW3G7hs9\r\nuTuizyyS0O7JxPG1BkCMiFQkzVBZH6dj6Ce95rXqvskapHUv6PwRCm2/1iaC\r\n9TKySDR3suUzZmRyyMlhU+TjQnFFYvlkI5J+uf+un0dAZTi0/QrW1QfqmRSR\r\ncLEsCO8rX1DUgsW/AifeAZqWni/6FvGWrWHzcKXA/2MetJqBQ6MMPbySQdLm\r\nWEyX8m4npUQe+axMenCdeQ3vIpt8j8wFqQRztyIPNcWATsz9jJHEq1S8Wvtk\r\nU7KbBLL+sVUCMSlOSBRtZvAbE4+b1/GI3wrkIpgnCSPCMyZApBrfgHFEVOsR\r\nbPqZ3vN4KYHa7imyUXdmA0BY0HjFttCcMQKu1glJeZ0yOI7UmTtu+W8P7r4f\r\nauihYDD3F56zuZ9ihYwr1h+Mvf5vaBaJoILpRpw8+a0g51K6GjDnZV3LIB9B\r\n/ii2N9cBovMQNl6e2ihkRwJlifcgfYx1/nM=\r\n=y7qu\r\n-----END PGP SIGNATURE-----\r\n"},"_npmUser":{"name":"akenzy","email":"lamhan3012@gmail.com"},"maintainers":[{"name":"akenzy","email":"lamhan3012@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka_0.0.2_1673850438835_0.45643911770017853"},"_hasShrinkwrap":false},"0.0.3":{"name":"@akenzy/kafka","version":"0.0.3","main":"dist/index.js","types":"dist/index.d.ts","license":"ISC","description":"Kafka module for NestJS","repository":{"type":"gitlab","url":"https://gitlab.com/akenzy/kenzy-kafka-module"},"type":"commonjs","author":{"name":"lamhoangancmvn","email":"lamhan3012@gmail.com"},"scripts":{"build":"tsc -p tsconfig.build.json","prepublishOnly":"yarn build"},"dependencies":{"@nestjs/common":"^9.0.0","@nestjs/core":"^9.0.0","kafkajs":"^2.2.3","rxjs":"^7.2.0"},"devDependencies":{"typescript":"^4.7.4"},"_id":"@akenzy/kafka@0.0.3","dist":{"shasum":"cc4c55b4a86705a3b2d09c656ac5df14c4264822","integrity":"sha512-Mh6qqzmL0PgfpINQc1625EW5VCQ9hItW2epUACFp3v4YfIp6L8ballI+AWnfXWYREeCiRturkkO3K4yawWUACQ==","tarball":"https://registry.npmjs.org/@akenzy/kafka/-/kafka-0.0.3.tgz","fileCount":20,"unpackedSize":11402,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQCbupk6NDeHSn4UKwmF2mk/nUNsAEAgzZRI8ThTP+PpswIgFudMh9xJZ0FmSQkDxdgqXPiMOiH+GKh8E3MTEuuBe+Y="}],"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v4.10.10\r\nComment: https://openpgpjs.org\r\n\r\nwsFzBAEBCAAGBQJjxPlLACEJED1NWxICdlZqFiEECWMYAoorWMhJKdjhPU1b\r\nEgJ2VmpVwA/+KSwqsTWjzkmCliJocwnuZtDyE3Tzo1Y0LPCDwuMGuPafIkAD\r\nR1qJGd2dbxgVtnWYHadyLxpfbHi/5MhKvcLtNzbHoRPNCzcsZdDr9xw4amIQ\r\nunpgvpICic0+yvDv7sCVbcaPpkPxz9WFNDJB/KTbvMTXxoCrKUZwPK+JlTw3\r\n9JXmDGPrf6nr3aqQ9V8nSaTFlT0DojFhRyHTYsBRwky+I9FvN0jQhZIDv7FQ\r\niBRr1Qq0NbFX3hT1kjr3zDzjhsTlqSgxNSv7hpS/v1FdyYUXnxTsSa5Uunq2\r\nL2RrKHwNBz3IHoQi5AoxR/+DggoE/+cBUbH4zOijBQTPPy8jLKeU8c05CG22\r\ndsx0JQXv0GxQcZr9TO0vsfD2fKowRRuSgp0Orl8FEqB0ZdvctclOJG5ugL7w\r\nVbd0Zf/66HEyouCtAUO1bVlLnq8U9kOEhA0kQQjAdxcH/y7A4jZifQ/Emepe\r\nfPF+BJRMJl3FnGD2UMwJuRC5ICLmloIpK9SO2pIhm7jfoUfSYs0cTlyyU6eg\r\n4kjLacvEtEUmOHoKCGwNvudWFiOOGf5H0HEGQ5nUNr02Img3ih4w55IVzKwH\r\nv49GxHMcN/aP6AtwhHYmS/D3bpSnT7rsN8Ovn08X8A+v2FIoRmOkPxpnntIi\r\nQ1TOd9yEMj1iYRFUFB6ltIRkeupVjSfK3tk=\r\n=4lrp\r\n-----END PGP SIGNATURE-----\r\n"},"_npmUser":{"name":"akenzy","email":"lamhan3012@gmail.com"},"directories":{},"maintainers":[{"name":"akenzy","email":"lamhan3012@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka_0.0.3_1673853258848_0.23236039548046294"},"_hasShrinkwrap":false},"0.0.4":{"name":"@akenzy/kafka","version":"0.0.4","main":"dist/index.js","types":"dist/index.d.ts","license":"ISC","description":"Kafka module for NestJS","repository":{"type":"gitlab","url":"https://gitlab.com/akenzy/kenzy-kafka-module"},"type":"commonjs","author":{"name":"lamhoangancmvn","email":"lamhan3012@gmail.com"},"scripts":{"build":"tsc -p tsconfig.build.json","prepublishOnly":"yarn build"},"dependencies":{"@nestjs/common":"^9.0.0","@nestjs/core":"^9.0.0","kafkajs":"^2.2.3","rxjs":"^7.2.0"},"devDependencies":{"typescript":"^4.7.4"},"_id":"@akenzy/kafka@0.0.4","dist":{"shasum":"43b316c9e47a55f55a9345c1bf4124417bef1e38","integrity":"sha512-GPOMDMYOEvZIpiIrvDgowvCiaoWXEqIZLZ9okR68X/Ogn/fS9ofQUbt25olmg85PlZe4RQKUgEXhoU8jCaSWQg==","tarball":"https://registry.npmjs.org/@akenzy/kafka/-/kafka-0.0.4.tgz","fileCount":20,"unpackedSize":11377,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCQyWqt4Aiewqv23vQODkdycNar2iGVjg+x+lNInm5DwAIhAMIIEwm6qsShTZKljDOLjHbXrzAsico+T+M1Vl47caXv"}],"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v4.10.10\r\nComment: https://openpgpjs.org\r\n\r\nwsFzBAEBCAAGBQJjxQp8ACEJED1NWxICdlZqFiEECWMYAoorWMhJKdjhPU1b\r\nEgJ2VmrcXQ//Vbc7ZTcwwpAjRXdLA8d1kSVRRSIsAGvsoaQJbft8ZP+k2fue\r\nvGhzpxfftvp/tQsJKjWBK/reDTh8m7iYVTINDC2fOYx53xTmbjcksAwV4Obi\r\ndUw8/OMiC6jSInCSENsPcQpiuU8GULM/EyoNtF5G1ixiEBBDV2o0msvVP3pV\r\nzJ6EthIW5bsbZeGLCMB88Cafpmv4v2TByjgwGMaKVMJyCawNOn9DkG4+ZEG3\r\n9v/BbE5YLrbFNpWrXEgt6pV/u95VjL8DSig2IX4EyOkLq5R76r9dEH2q71jL\r\nZi8+N/PJvy5qdH4GVQxO++xIVt2E4t6IRlWCI1EfYHMNqrVnzkwYy9OHlY5o\r\n/blOZx2LI/8N91EcBIYPr39tYXCgohI5X41RjMotnJL3/1KPdkRKSs3P8Uzs\r\n1FPo47WPPWU0che/r0XvV7PHjO0Rh0T58zquzUi0C655oAEOmgP/fynPAcgx\r\npon3C0epZsH/WDeFl8JD0UctK7ySmJd2kc8rOHOrlNo8pwoizfy3XjbvUUtr\r\n+OuMX340LkW8ytL5gN8rE5VXNkFs5W52cQ/xT/A6njcW4M1l/jiOIwICLTwb\r\nMrO3OyWnMCixkANekje0F0GROfjFjEmP0g8QJtYIVpR+hwk0QQN7zvMXTRYq\r\nT2NeEJ7M05Ev5BPFZugLBsmtWtoy3xNAfkc=\r\n=RjQd\r\n-----END PGP SIGNATURE-----\r\n"},"_npmUser":{"name":"akenzy","email":"lamhan3012@gmail.com"},"directories":{},"maintainers":[{"name":"akenzy","email":"lamhan3012@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka_0.0.4_1673857660740_0.5402445148606052"},"_hasShrinkwrap":false}},"time":{"created":"2023-01-16T05:04:47.603Z","0.0.1":"2023-01-16T05:04:47.829Z","modified":"2023-01-16T08:27:41.061Z","0.0.2":"2023-01-16T06:27:19.014Z","0.0.3":"2023-01-16T07:14:18.973Z","0.0.4":"2023-01-16T08:27:40.912Z"},"maintainers":[{"name":"akenzy","email":"lamhan3012@gmail.com"}],"description":"Kafka module for NestJS","repository":{"type":"gitlab","url":"https://gitlab.com/akenzy/kenzy-kafka-module"},"author":{"name":"lamhoangancmvn","email":"lamhan3012@gmail.com"},"license":"ISC","readme":"<img src=\"\">\n\n# NestJS + KafkaJS\n</line>\nIntegrate of KafkaJs with NestJs handling retry and error.\n\n## Setup KafkaJS Module\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\nRegister the KafkaModule synchronous with the forRoot() method:\n```\nimport { Module } from '@nestjs/common';\nimport { AppController } from './app.controller';\nimport { AppService } from './app.service';\nimport { KafkaModule } from '@kenzy/kafka';\nimport { ConfigModule } from '@nestjs/config';\nimport { TestConsumer } from './test.consumer';\n\n@Module({\n  imports: [\n    KafkaModule.forRoot({\n      broker: ['localhost:9092', 'localhost:9093', 'localhost:9094'],\n    }),\n    ConfigModule.forRoot({ isGlobal: true }),\n  ],\n  controllers: [AppController],\n  providers: [AppService, TestConsumer],\n})\nexport class AppModule {}\n```\n\n#### Handle Produce KafkaJS\nEX: using class **ProducerService**\n```\nimport { ProducerService } from '@kenzy/kafka';\nimport { Injectable } from '@nestjs/common';\n\n@Injectable()\nexport class AppService {\n  constructor(private readonly producerService: ProducerService) {}\n\n  async getHello(): Promise<string> {\n    await this.producerService.produce('test', {\n      value: 'Kenzy test message Kafka',\n    });\n    return 'Hello World!';\n  }\n}\n\n```\n\n#### Handle Consume KafkaJS\nEX: using class **ConsumerService**\nPS: Create file {name}.consumer.ts\nimport init Service Module Example My App\n```\nimport { ConsumerService } from '@kenzy/kafka/dist';\nimport { Injectable, OnModuleInit } from '@nestjs/common';\n\n@Injectable()\nexport class TestConsumer implements OnModuleInit {\n  constructor(private readonly consumerService: ConsumerService) {}\n\n  async onModuleInit() {\n    await this.consumerService.consume({\n      topic: { topic: 'test' },\n      config: { groupId: 'test-consumer' },\n      onMessage: async (message) => {\n        console.log({\n          value: message.value.toString(),\n        });\n        // throw new Error('Test error!');\n      },\n    });\n  }\n}\n\n```\n\n\nCreate By AKenzy\nEmail: lamhan3012@gmail.com\nDate: 16/01/2023","readmeFilename":"Readme.md"}