{"_id":"@opuscapita/kafka-client","_rev":"37-9a6ff2e6a60b64f5f41e6df254f47102","name":"@opuscapita/kafka-client","dist-tags":{"latest":"2.0.2"},"versions":{"1.0.0":{"name":"@opuscapita/kafka-client","version":"1.0.0","keywords":[],"author":"","license":"ISC","_id":"@opuscapita/kafka-client@1.0.0","maintainers":[{"name":"kaputse","email":"denbuec@gmail.com"},{"name":"adam-dziomdziora-cybercom","email":"adam.dziomdziora@cybercom.com"},{"name":"zjuice","email":"juhani.lindfors@opuscapita.com"},{"name":"jluukka","email":"joel.luukka@opuscapita.com"},{"name":"nkovalenko-sc","email":"nikolai.kovalenko@opuscapita.com"},{"name":"bo-kh","email":"boris.khorosh@gmail.com"},{"name":"pdetmer","email":"detmerpiotr@gmail.com"},{"name":"janek.bug","email":"janek.bug@gmail.com"},{"name":"alexeysergeev","email":"sab@scand.com"},{"name":"kirillvolkovich","email":"kirill.volkovich@opuscapita.com"},{"name":"gr4per","email":"arne.graeper@opuscapita.com"},{"name":"ilkkalehtinen","email":"ilkka.lehtinen@opuscapita.com"},{"name":"havantkim","email":"kimmo.havantola@opuscapita.com"},{"name":"eriihine","email":"esa.riihinen@gmail.com"},{"name":"tamkov-sc","email":"tamkov@scand.com"},{"name":"kwierchris","email":"christian.drengenberg@opuscapita.com"},{"name":"elefantino","email":"net.tyumen@mail.ru"},{"name":"samikarj","email":"samikarj@gmail.com"},{"name":"dsanko","email":"dsanko@scand.com"},{"name":"dmitrydivin","email":"divin.dmitry@gmail.com"},{"name":"alexanderdanilov","email":"adanilov@scand.com"},{"name":"egor.stambakio","email":"egor.stambakio@opuscapita.com"},{"name":"amourzenkov-sc","email":"andrei.mourzenkov@opuscapita.com"},{"name":"jenni","email":"jenni.ristonmaa@gmail.com"},{"name":"nczeranka","email":"norbert.czeranka@opuscapita.com"},{"name":"ocmachineuser","email":"pim.machineuser@opuscapita.com"},{"name":"lukaszkepa","email":"lke.kemps@gmail.com"},{"name":"naniantero","email":"jani@geniem.com"}],"homepage":"https://github.com/OpusCapita/kafka-client#readme","bugs":{"url":"https://github.com/OpusCapita/kafka-client/issues"},"dist":{"shasum":"b353653e06893ff05165a0b031de241af5a5b3fb","tarball":"https://registry.npmjs.org/@opuscapita/kafka-client/-/kafka-client-1.0.0.tgz","fileCount":46,"integrity":"sha512-gGFzsn9KhZJx/2tXhwRuZ4Gqkpg8ov0V7BajJicYAzX4Co5gfWMLT2LjyQiWpmXcBl8DIhqjVEAfI2LivpRaoA==","signatures":[{"sig":"MEQCIHqkvGXkkYo1N2NxlfgUAZOkLDVl5jb++Ag6mmv+IFLGAiBR6OAKWmDpkI+yLegjY4YQBfyG5AQV9zLT+ECXsfcdVg==","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":117336,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJdI0adCRA9TVsSAnZWagAAaSwP/RE0MZ9yrU6hnNR172vE\nUST/m9gBTZG0slX2rJJdEz5Ww3XYdvu+9h6xfKcw0qRkM1fj7sPgMgdmZxsz\n4wsNTP8uabxU2E0Txo0+sSLGNKvyZpXypkz0knpNgXyBm+lj5MdAVy3Z2pfC\n1jjfIFjTsFdg5obLIJXiQIqXlSbBzTrpgtgutMYP3W407cbDeidAkGsQ+QqJ\nUr1e0niWLn/24w2jGV40p0qx+QpS2eWve+Yj5a1QVtuyO6PE2AUXRQRc80BQ\nosVzJNtiyjDBMq1UrolAtwY+ZLhx7/Izg21IabTH1ioj/6AzodJeMX/wrTnv\nDZ4zuYzFJIbe2mziDxIitOh+WPCbwByzESjPI0dd73k6CBDo+dHdc67rnUX5\neSpVVHl2Do7aOfnFH7F+E3/u6F7iroIqa82aHTMgffG28BeE4cHC5LVnRAr7\n/MSKshFzdQxpgcAJxqwXXMyFfoNvb6+rD30kwPILuii4ejp9DfxNEyZMl5Y4\n7vpz5pIsqV7mvM9eu5IyCbCOCQ2EQhidmc1O6lWdPmxSQXJSpPWituWg2wDU\nis47G+T+0KrtrW9a9OitsdSvPYnEbEcwPoRbSMkN2kgvjj12XHfs+EGA23gZ\nZEDrohh4oAr9Xo/juf4dNuykNQt5qTBJRXvPFlHVzAV3WbPJtAaxAq/4xAg5\ncA7P\r\n=s9x9\r\n-----END PGP SIGNATURE-----\r\n"},"main":"dist/index.js","gitHead":"278a41dd42a76510da50c878435b6ba268b05233","scripts":{"dev":"npx nodemon","test":"npx mocha -r ts-node/register tests/**/*.spec.ts","build":"tsc","debug":"npx nodemon --exec 'ts-node' local/debug.ts","test:watch":"npx mocha --opts mocha.opts --watch","start:debug":"node --inspect index.js","prepublishOnly":"npm run build","start:debug:ts":"npx nodemon --config nodemon-debug.json","start:debug:brk":"node --inspect-brk index.js","test:watch:debug":"npx mocha --inspect=0.0.0.0:9230 --opts mocha.opts --watch","start:debug:ts:brk":"node --inspect-brk --require ts-node/register index.ts"},"_npmUser":{"name":"kaputse","email":"denbuec@gmail.com"},"deprecated":"Consider using vanilla KafkaJS instead. This library is not used, not maintained for a long time and has several serious limitations including autocommit (for highly reliable systems you probably prefer better protection from lost messages), execution of consumers in separate calls (making it more difficult to handle full batch together for bound messages), lack of solid documentation and possibly hiding some kafkajs interfaces from you","repository":{"url":"git+https://github.com/OpusCapita/kafka-client.git","type":"git"},"_npmVersion":"6.9.0","description":"OpusCapita kafka client library.","directories":{},"_nodeVersion":"8.16.0","dependencies":{"extend":"^3.0.2","kafkajs":"^1.9.3","ocbesbn-logger":"^1.0.11","@opuscapita/config":"^3.0.16"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.2.0","mocha":"^6.1.4","ts-node":"^8.3.0","typescript":"^3.5.2","@types/chai":"^4.1.7","@types/node":"^12.0.12","@types/mocha":"^5.2.7","@types/extend":"^3.0.1","@types/kafkajs":"^1.8.2"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_1.0.0_1562592924413_0.025691437460421573","host":"s3://npm-registry-packages"}},"1.0.1":{"name":"@opuscapita/kafka-client","version":"1.0.1","keywords":[],"author":"","license":"ISC","_id":"@opuscapita/kafka-client@1.0.1","maintainers":[{"name":"adam-dziomdziora-cybercom","email":"adam.dziomdziora@cybercom.com"},{"name":"alexanderdanilov","email":"adanilov@scand.com"},{"name":"alexeysergeev","email":"sab@scand.com"},{"name":"amourzenkov-sc","email":"andrei.mourzenkov@opuscapita.com"},{"name":"bo-kh","email":"boris.khorosh@gmail.com"},{"name":"dmitrydivin","email":"divin.dmitry@gmail.com"},{"name":"dsanko","email":"dsanko@scand.com"},{"name":"egor.stambakio","email":"egor.stambakio@opuscapita.com"},{"name":"elefantino","email":"net.tyumen@mail.ru"},{"name":"eriihine","email":"esa.riihinen@gmail.com"},{"name":"gr4per","email":"arne.graeper@opuscapita.com"},{"name":"havantkim","email":"kimmo.havantola@opuscapita.com"},{"name":"ilkkalehtinen","email":"ilkka.lehtinen@opuscapita.com"},{"name":"janek.bug","email":"janek.bug@gmail.com"},{"name":"jenni","email":"jenni.ristonmaa@gmail.com"},{"name":"jluukka","email":"joel.luukka@opuscapita.com"},{"name":"kaputse","email":"denbuec@gmail.com"},{"name":"kirillvolkovich","email":"kirill.volkovich@opuscapita.com"},{"name":"kwierchris","email":"christian.drengenberg@opuscapita.com"},{"name":"lukaszkepa","email":"lke.kemps@gmail.com"},{"name":"naniantero","email":"jani@geniem.com"},{"name":"nczeranka","email":"norbert.czeranka@opuscapita.com"},{"name":"nkovalenko-sc","email":"nikolai.kovalenko@opuscapita.com"},{"name":"ocmachineuser","email":"pim.machineuser@opuscapita.com"},{"name":"pdetmer","email":"detmerpiotr@gmail.com"},{"name":"samikarj","email":"samikarj@gmail.com"},{"name":"tamkov-sc","email":"tamkov@scand.com"},{"name":"zjuice","email":"juhani.lindfors@opuscapita.com"}],"homepage":"https://github.com/OpusCapita/kafka-client#readme","bugs":{"url":"https://github.com/OpusCapita/kafka-client/issues"},"dist":{"shasum":"2a662035f5a5efffd8c3e94d71bca1d2f2d68af6","tarball":"https://registry.npmjs.org/@opuscapita/kafka-client/-/kafka-client-1.0.1.tgz","fileCount":46,"integrity":"sha512-DeL8/GSXvjEjheg35qWL2Nd74XVIU4mTBbkyCqESvh0qtbcjwlr3Bacs29P4kGbRMJuepb70wYK0eXklIfRm0w==","signatures":[{"sig":"MEQCIB3tp1nCRejHPZq4hxokjhSYiRoMtHDO1My4DKQRrxW2AiBnKB0HbbIwLeqTEOXEVKc9M+Hu+yieDnhwcQ2LdZCplg==","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":117465,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJdI1OpCRA9TVsSAnZWagAAa1YQAI1TDpNmtQZGVvpmsU1E\nfCrXI2z2VBBfl1uCQtv8fk/PUkckFdScTiyzrFVXYph2MjnUIMzT2hrkZZYB\nV2PtvL8u7xwddYNqPzIXeH6bkdevAowdBgcVbLY35Se+DW/Dcg82VahGiokn\nA8ovhyLyL5R3o5zcJnY/at9fPOSDScNWDq678ThAFHka1rNwtjT4wGy/Hqae\ns+QZ+APMTRCY/oHvPpMaZdxOkZD7FMZAmgdGvfIqlpajvaW7He/txCLLuUWD\nWEsHSX0L0dtAKrmEg1AzUwMNWOyH1fXcw96CTH0bwWmqX/uVCrpF6zNxswqL\nXOTb2mqPdbFe3xY90n5bv2YM4oPkztfehb1/c6U/8g9ySxVbeVeI3jAcN2Pp\nbcI8WvAPoRWCGzlBfsckvUwD+Jg1guaHH15UCi5CVxkPFYQ5cImRIMToyMsm\nsxCzgsiY5HhjzL55bRDM6Z63vf1xSF8RYD1yervkW1z/gjq0H9ILgzeDc23S\n/8KNAKzvJEf9u2jfo2DfHtUYpwIrHTVJrrYxTRzoWnNWx8NZQ82gGkpV8nzw\nHuB1q8r347Zkuu5xqaFpiX6GePvJlR70GdTp6Y7/QvT/Vsf5yYqt0IjRJv0D\nDmfY4j0n0AFWdNmsP4rQhzpSZY+O3vzEzxEMj78m4kxkL4MqJ1s1z4PkwKjQ\nGV6N\r\n=/6aR\r\n-----END PGP SIGNATURE-----\r\n"},"main":"dist/index.js","gitHead":"f2423a405c9b523b6f9dd667ce1fb4ac3af7bc46","scripts":{"dev":"npx nodemon","test":"npx mocha -r ts-node/register tests/**/*.spec.ts","build":"tsc","debug":"npx nodemon --exec 'ts-node' local/debug.ts","test:watch":"npx mocha --opts mocha.opts --watch","start:debug":"node --inspect index.js","prepublishOnly":"npm run build","start:debug:ts":"npx nodemon --config nodemon-debug.json","start:debug:brk":"node --inspect-brk index.js","test:watch:debug":"npx mocha --inspect=0.0.0.0:9230 --opts mocha.opts --watch","start:debug:ts:brk":"node --inspect-brk --require ts-node/register index.ts"},"_npmUser":{"name":"kaputse","email":"denbuec@gmail.com"},"deprecated":"Consider using vanilla KafkaJS instead. This library is not used, not maintained for a long time and has several serious limitations including autocommit (for highly reliable systems you probably prefer better protection from lost messages), execution of consumers in separate calls (making it more difficult to handle full batch together for bound messages), lack of solid documentation and possibly hiding some kafkajs interfaces from you","repository":{"url":"git+https://github.com/OpusCapita/kafka-client.git","type":"git"},"_npmVersion":"6.9.0","description":"OpusCapita kafka client library.","directories":{},"_nodeVersion":"8.16.0","dependencies":{"extend":"^3.0.2","kafkajs":"^1.9.3","ocbesbn-logger":"^1.0.11","@opuscapita/config":"^3.0.16"},"_hasShrinkwrap":false,"devDependencies":{"chai":"^4.2.0","mocha":"^6.1.4","ts-node":"^8.3.0","typescript":"^3.5.2","@types/chai":"^4.1.7","@types/node":"^12.0.12","@types/mocha":"^5.2.7","@types/extend":"^3.0.1","@types/kafkajs":"^1.8.2"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_1.0.1_1562596265325_0.006161108496685275","host":"s3://npm-registry-packages"}},"1.0.2":{"name":"@opuscapita/kafka-client","version":"1.0.2","keywords":[],"author":"","license":"ISC","_id":"@opuscapita/kafka-client@1.0.2","maintainers":[{"name":"adam-dziomdziora-cybercom","email":"adam.dziomdziora@cybercom.com"},{"name":"alexanderdanilov","email":"adanilov@scand.com"},{"name":"alexeysergeev","email":"sab@scand.com"},{"name":"amourzenkov-sc","email":"andrei.mourzenkov@opuscapita.com"},{"name":"bo-kh","email":"boris.khorosh@gmail.com"},{"name":"dmitrydivin","email":"divin.dmitry@gmail.com"},{"name":"dsanko","email":"dsanko@scand.com"},{"name":"egor.stambakio","email":"egor.stambakio@opuscapita.com"},{"name":"elefantino","email":"net.tyumen@mail.ru"},{"name":"eriihine","email":"esa.riihinen@gmail.com"},{"name":"gr4per","email":"arne.graeper@opuscapita.com"},{"name":"havantkim","email":"kimmo.havantola@opuscapita.com"},{"name":"ilkkalehtinen","email":"ilkka.lehtinen@opuscapita.com"},{"name":"janek.bug","email":"janek.bug@gmail.com"},{"name":"jenni","email":"jenni.ristonmaa@gmail.com"},{"name":"jluukka","email":"joel.luukka@opuscapita.com"},{"name":"kaputse","email":"denbuec@gmail.com"},{"name":"kirillvolkovich","email":"kirill.volkovich@opuscapita.com"},{"name":"kwierchris","email":"christian.drengenberg@opuscapita.com"},{"name":"lukaszkepa","email":"lke.kemps@gmail.com"},{"name":"naniantero","email":"jani@geniem.com"},{"name":"nczeranka","email":"norbert.czeranka@opuscapita.com"},{"name":"nkovalenko-sc","email":"nikolai.kovalenko@opuscapita.com"},{"name":"ocmachineuser","email":"pim.machineuser@opuscapita.com"},{"name":"pdetmer","email":"detmerpiotr@gmail.com"},{"name":"samikarj","email":"samikarj@gmail.com"},{"name":"tamkov-sc","email":"tamkov@scand.com"},{"name":"zjuice","email":"juhani.lindfors@opuscapita.com"}],"homepage":"https://github.com/OpusCapita/kafka-client#readme","bugs":{"url":"https://github.com/OpusCapita/kafka-client/issues"},"dist":{"shasum":"4982ef973379583f32b4dc00bde98a4578762593","tarball":"https://registry.npmjs.org/@opuscapita/kafka-client/-/kafka-client-1.0.2.tgz","fileCount":45,"integrity":"sha512-tzpjoPjJTf0kS7e32+O+HAsbJcNFH86xoCkZ90zSvrpq3FXXBWTZKiMYUhsVo6/OG5KT+7+EX9Z4ca4IMpTsHw==","signatures":[{"sig":"MEUCIQDJb7dp4x5WXYEP/xxoLYysPzKI/IyIL3yQMFzelMd/TwIgEMJcc/YxOfyzPSf5d0VetxCDQVcgljV39hc1PqBZEE8=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":110295,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJdJ0yoCRA9TVsSAnZWagAA1XUQAJ0lI2XGTdoH8ujfH8Rd\ngNi+Tm6GrUGbBwUxwmFzcOlf6XJGOYSahuhXYOZEWAtUmYC5yDUijHVHgC9L\nvyVKnl3nIRfHLEVVj0CAVeL0ICV7s1t6wxDG92l1Fy6pNeDgXEXB8UEYXpwA\nX5dS8U2LRTxhn5yG0ZZZFhblWC4YcKKX32u6R7b85Ob1GCRpVBc+RgOKFMH2\ntbhNGD+z1C6zO4GKzoSMS/m8coyRAUQmuxH7mEGHIH81ISn1sRjOpKE2ExUY\nDVCWcyGFMopCPfyLV5Ltmgujg3kbD8O8eCU39NRfzH356TkyvuxRxzBJqHYH\nA4LMhy8/luKYSomFXPEuYIc1TC/YbBZRnZ1EnMCGSoThVX93kkTckLhkIWUc\nz5icnsmerwb2ubnw4EQalNK/Rv3mCyyyCkWg4jovlAFD/2IrdnK8wJp5bNH0\ntkGXboK/6pC0mf38WEtjkT9bhZmI0jsTc6LKpOzRaPwXrRzVHif0vsUJbPJi\nPTKwDbGXAhJNfkMbEluFbSpyQEF9Wx0Uo7JIa4yMj9TRtkH6US/IuD6I2TMY\nw8Ze0qgQ/JGp13Zw5IhKIWr6P2Nfry5WcDjYeSLBCVs0YQXYngmD6pFxZ0rJ\nrjqcbyMbXz15xqZiz1snWosEUEUi7Eo9AmvoZhpKRa8IMVbuHcEmTHjLJqpN\n3iwN\r\n=6GqF\r\n-----END PGP SIGNATURE-----\r\n"},"main":"dist/index.js","gitHead":"a3a83a9909fd4f56499599ad95ceb853665c5933","scripts":{"dev":"npx nodemon","test":"npx mocha --timeout 120000 -r ts-node/register tests/**/*.spec.ts","build":"tsc","clean":"npx rimraf .nyc_output coverage test-results.xml","debug":"npx nodemon --exec 'ts-node' local/debug.ts","test:watch":"npx mocha --opts mocha.opts --watch","start:debug":"node --inspect index.js","test:coverage":"npm run clean ; npx nyc --reporter=lcov mocha --timeout 120000 --opts mocha.opts && sed -i 's/\\/home\\/node\\/kafka-client\\//\\.\\//g' coverage/lcov.info","prepublishOnly":"npm run build","start:debug:ts":"npx nodemon --config nodemon-debug.json","start:debug:brk":"node --inspect-brk index.js","upload-coverage":"cat ./coverage/lcov.info | npx coveralls","test:watch:debug":"npx mocha --inspect=0.0.0.0:9230 --opts mocha.opts --watch","start:debug:ts:brk":"node --inspect-brk --require ts-node/register index.ts"},"_npmUser":{"name":"kaputse","email":"denbuec@gmail.com"},"deprecated":"Consider using vanilla KafkaJS instead. This library is not used, not maintained for a long time and has several serious limitations including autocommit (for highly reliable systems you probably prefer better protection from lost messages), execution of consumers in separate calls (making it more difficult to handle full batch together for bound messages), lack of solid documentation and possibly hiding some kafkajs interfaces from you","repository":{"url":"git+https://github.com/OpusCapita/kafka-client.git","type":"git"},"_npmVersion":"5.4.2","description":"OpusCapita kafka client library.","directories":{},"_nodeVersion":"6.1.0","dependencies":{"extend":"^3.0.2","kafkajs":"^1.9.3","ocbesbn-logger":"^1.0.11","@opuscapita/config":"^3.0.16"},"_hasShrinkwrap":false,"devDependencies":{"nyc":"^11.8.0","chai":"^4.2.0","mocha":"^6.1.4","rimraf":"^2.6.2","ts-node":"^8.3.0","typescript":"^3.5.3","@types/chai":"^4.1.7","@types/node":"^12.6.2","@types/mocha":"^5.2.7","@types/extend":"^3.0.1","@types/kafkajs":"^1.8.2"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_1.0.2_1562856615544_0.5654520222158745","host":"s3://npm-registry-packages"}},"1.0.3":{"name":"@opuscapita/kafka-client","version":"1.0.3","keywords":[],"author":"","license":"ISC","_id":"@opuscapita/kafka-client@1.0.3","maintainers":[{"name":"adam-dziomdziora-cybercom","email":"adam.dziomdziora@cybercom.com"},{"name":"alexanderdanilov","email":"adanilov@scand.com"},{"name":"alexeysergeev","email":"sab@scand.com"},{"name":"amourzenkov-sc","email":"andrei.mourzenkov@opuscapita.com"},{"name":"bo-kh","email":"boris.khorosh@gmail.com"},{"name":"dmitrydivin","email":"divin.dmitry@gmail.com"},{"name":"dsanko","email":"dsanko@scand.com"},{"name":"egor.stambakio","email":"egor.stambakio@opuscapita.com"},{"name":"elefantino","email":"net.tyumen@mail.ru"},{"name":"eriihine","email":"esa.riihinen@gmail.com"},{"name":"gr4per","email":"arne.graeper@opuscapita.com"},{"name":"havantkim","email":"kimmo.havantola@opuscapita.com"},{"name":"ilkkalehtinen","email":"ilkka.lehtinen@opuscapita.com"},{"name":"janek.bug","email":"janek.bug@gmail.com"},{"name":"jenni","email":"jenni.ristonmaa@gmail.com"},{"name":"jluukka","email":"joel.luukka@opuscapita.com"},{"name":"kaputse","email":"denbuec@gmail.com"},{"name":"kirillvolkovich","email":"kirill.volkovich@opuscapita.com"},{"name":"kwierchris","email":"christian.drengenberg@opuscapita.com"},{"name":"lukaszkepa","email":"lke.kemps@gmail.com"},{"name":"naniantero","email":"jani@geniem.com"},{"name":"nczeranka","email":"norbert.czeranka@opuscapita.com"},{"name":"nkovalenko-sc","email":"nikolai.kovalenko@opuscapita.com"},{"name":"ocmachineuser","email":"pim.machineuser@opuscapita.com"},{"name":"pdetmer","email":"detmerpiotr@gmail.com"},{"name":"samikarj","email":"samikarj@gmail.com"},{"name":"tamkov-sc","email":"tamkov@scand.com"},{"name":"zjuice","email":"juhani.lindfors@opuscapita.com"}],"homepage":"https://github.com/OpusCapita/kafka-client#readme","bugs":{"url":"https://github.com/OpusCapita/kafka-client/issues"},"dist":{"shasum":"9faa3e10c3946852e4c6daf1953a5010c4b5c273","tarball":"https://registry.npmjs.org/@opuscapita/kafka-client/-/kafka-client-1.0.3.tgz","fileCount":47,"integrity":"sha512-3axV8CacBNUMcLZGwX4ut//Y/RookARcL7sbrVjAxFD6EIW986PYete6LgNkw4I4eLMALJK5u4+Er+dvqexB8Q==","signatures":[{"sig":"MEUCICj5OIENtBPv5m+fP8pRIUF0IqwSqNjD/4L1zVECwiZsAiEAilxMiWXp+2jHLFrt9QQbm3LkzAyXCBxB3CHsS3FoCH4=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":110539,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJdKFoOCRA9TVsSAnZWagAA45YQAJPU+Q8egXPwYN3Y6ncs\n5OE3iqruHQOmWFg2C6MxzL0cdKkW7jvLcYGi3xzADl9cpNEWbNM9gjOnR/Z1\n8MYXQNIMuZ6uGAjToW8h0LGg9EYvLi3vMg0O6e4RqlojBBcQqGfZvQRaTFGN\nf9Z0ab6Xb5lgK710EqedF0ocKp6SHSvprph2dDIowvIEsPid8/8Re+OBWnNC\nT18/gkx+ATUE0EDYNvlM/VQjK0TxgMib4/Ml1uv1oSnor33px4vOszA+2DdC\nbL0W2vLjFA07N8L6GK4nTGmiP/gOSRIg2GPmkHRF/u8ZjHANAY17CviE/Jn7\nHLfb9scoJhufoVTWIJiKuP7SuRVsNQfmbIA3oQVvCB+1uZ4yVfkZTkOSgZDh\nUcol7S7db5RUorVSZnK+HDTxOorZbfQkdFIvxBMx9A3VSoM8+Yb3JV7jI2AU\n3OR2ixQ+OiKWFvOaagG87jhroVsB9kGQDva44dyTsipXCHcFQW0x35Bkjiw1\n+edSSslLCsc95crTxt/PCqwoYRA7ITS0qN3mU8NnkmCJrv8E+e+mfIArXhz+\n9lfz2YQWICfVQXxl39expSq3VO7uKwBFh5m/D30UQzepcsR2BSeHwqYf/Rkj\nYKXmF2lblZfFdoI45U7vj93X51BG4v6N/lTWERNPoaxs2BuK7sBhfrkCYxQ9\nX0cw\r\n=qLeV\r\n-----END PGP SIGNATURE-----\r\n"},"main":"dist/index.js","gitHead":"f8e0341270d156342601bfacde7483990ca0eae9","scripts":{"dev":"npx nodemon","test":"npx mocha --timeout 120000 -r ts-node/register tests/**/*.spec.ts","build":"tsc","clean":"npx rimraf .nyc_output coverage/lcov* test-results.xml","debug":"npx nodemon --exec 'ts-node' local/debug.ts","test:watch":"npx mocha --opts mocha.opts --watch","test:coverage":"npm run clean ; npx nyc --reporter=lcov mocha --opts mocha.opts && sed -i 's/\\/home\\/node\\/kafka-client\\//\\.\\//g' coverage/lcov.info","prepublishOnly":"npm run build","start:debug:ts":"npx nodemon --config nodemon-debug.json","upload-coverage":"cat ./coverage/lcov.info | npx coveralls","test:watch:debug":"npx mocha --inspect=0.0.0.0:9230 --opts mocha.opts --watch","start:debug:ts:brk":"node --inspect-brk --require ts-node/register index.ts"},"_npmUser":{"name":"kaputse","email":"denbuec@gmail.com"},"deprecated":"Consider using vanilla KafkaJS instead. This library is not used, not maintained for a long time and has several serious limitations including autocommit (for highly reliable systems you probably prefer better protection from lost messages), execution of consumers in separate calls (making it more difficult to handle full batch together for bound messages), lack of solid documentation and possibly hiding some kafkajs interfaces from you","repository":{"url":"git+https://github.com/OpusCapita/kafka-client.git","type":"git"},"_npmVersion":"5.4.2","description":"OpusCapita kafka client library.","directories":{},"_nodeVersion":"6.1.0","dependencies":{"extend":"^3.0.2","kafkajs":"^1.9.3","ocbesbn-logger":"^1.0.11","@opuscapita/config":"^3.0.16"},"_hasShrinkwrap":false,"devDependencies":{"nyc":"^11.9.0","chai":"^4.2.0","mocha":"^6.1.4","rimraf":"^2.6.2","ts-node":"^8.3.0","typescript":"^3.5.3","@types/chai":"^4.1.7","@types/node":"^12.6.2","@types/mocha":"^5.2.7","@types/extend":"^3.0.1","@types/kafkajs":"^1.8.2","source-map-support":"^0.5.12","@istanbuljs/nyc-config-typescript":"^0.1.3"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_1.0.3_1562925581639_0.17811181376169527","host":"s3://npm-registry-packages"}},"1.0.4":{"name":"@opuscapita/kafka-client","version":"1.0.4","keywords":[],"author":"","license":"ISC","_id":"@opuscapita/kafka-client@1.0.4","maintainers":[{"name":"adam-dziomdziora-cybercom","email":"adam.dziomdziora@cybercom.com"},{"name":"alexanderdanilov","email":"adanilov@scand.com"},{"name":"alexeysergeev","email":"sab@scand.com"},{"name":"amourzenkov-sc","email":"andrei.mourzenkov@opuscapita.com"},{"name":"bo-kh","email":"boris.khorosh@gmail.com"},{"name":"dmitrydivin","email":"divin.dmitry@gmail.com"},{"name":"dsanko","email":"dsanko@scand.com"},{"name":"egor.stambakio","email":"egor.stambakio@opuscapita.com"},{"name":"elefantino","email":"net.tyumen@mail.ru"},{"name":"eriihine","email":"esa.riihinen@gmail.com"},{"name":"gr4per","email":"arne.graeper@opuscapita.com"},{"name":"havantkim","email":"kimmo.havantola@opuscapita.com"},{"name":"ilkkalehtinen","email":"ilkka.lehtinen@opuscapita.com"},{"name":"janek.bug","email":"janek.bug@gmail.com"},{"name":"jenni","email":"jenni.ristonmaa@gmail.com"},{"name":"jluukka","email":"joel.luukka@opuscapita.com"},{"name":"kaputse","email":"denbuec@gmail.com"},{"name":"kirillvolkovich","email":"kirill.volkovich@opuscapita.com"},{"name":"kwierchris","email":"christian.drengenberg@opuscapita.com"},{"name":"lukaszkepa","email":"lke.kemps@gmail.com"},{"name":"naniantero","email":"jani@geniem.com"},{"name":"nczeranka","email":"norbert.czeranka@opuscapita.com"},{"name":"nkovalenko-sc","email":"nikolai.kovalenko@opuscapita.com"},{"name":"ocmachineuser","email":"pim.machineuser@opuscapita.com"},{"name":"pdetmer","email":"detmerpiotr@gmail.com"},{"name":"samikarj","email":"samikarj@gmail.com"},{"name":"tamkov-sc","email":"tamkov@scand.com"},{"name":"zjuice","email":"juhani.lindfors@opuscapita.com"}],"homepage":"https://github.com/OpusCapita/kafka-client#readme","bugs":{"url":"https://github.com/OpusCapita/kafka-client/issues"},"dist":{"shasum":"6aca48a90caccb3639f571493f031d65cd8697ec","tarball":"https://registry.npmjs.org/@opuscapita/kafka-client/-/kafka-client-1.0.4.tgz","fileCount":47,"integrity":"sha512-LY5XWhjrgJ82BB1G/IUFiMugnMeT+F3N57mmqGGX8VU8fuDSsPwCi/YwE/ViXu9AxNmrOmDWurfkm3ZrsiontA==","signatures":[{"sig":"MEYCIQDdfsVGOzexir+eVathrhjP0ii2HfFIa+XTxwKgcJIlNwIhANUp4blLZ+z7BTTaD0sd4zfjPgsX5Og6ObPxR+L6dzdJ","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":128061,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJdN/xxCRA9TVsSAnZWagAAEzQQAKDwHpqZP6lhuOD5qv43\ny4Tlr/33V9K9mkw+aa8Dx1V2cmnModluZK20BR/0tI0JzHEpGrl4AScWC1wH\n88zf7Oq9qVFqduC3c23v02IfbCJU3GkEhZXMVXjsEaInp9s1tVT3FjpUfCpW\nnqCXG81FGUQnMY/bRGRNB7nZpBBpVZP0rjXQFhKdPU9JhLLYZ1TvamztWNT6\n6o1k9AfyKEBFmX9k45lFlow9KI8+2Kr0Chd6atBDMaL3O5uWsJkvjyGFZM8T\nb19SLYSSw4Mj/EaB4e6jRUaEdt/7B9ViH8LRH9u3QL1ziuhpCpjXpGg5O0SI\nhJe95lv60aMT5OhwnPqLKdEtMpgSxwe0OS1Je2H1w52trNq1szFid7FQp2+l\n//EIUnBraQAf/eF0BC3cNcPW14csVLs2UzROZagOIrB+AU40WZPtC1DQJKum\n/5qweXEJNs2SRwzK5zZaSbgqXxj5mMxiL7SCVJdgDxujmkXWgxN0oZPuzdF8\ny8cc0idixiHfmBBOda/k7V5OEOb2z7ScwMKG5qIx9Wbl3MlGX7fX+lW2XtdZ\nGwGPmdGWL2E46uMVcoKtSqF+6vRdXKZuqIcWYCM93b+YSBrV1WTQZx11R+io\nCPygRCypqbSPP5Dii2DW2BBbcsAeNZXIyhe2Ey+7lmVRMc4kiVvbik3WJR9d\nx2qg\r\n=C99k\r\n-----END PGP SIGNATURE-----\r\n"},"main":"dist/index.js","gitHead":"45b0255e86686abf09e38788c782df617b39f80f","scripts":{"dev":"npx nodemon","test":"npx mocha --timeout 120000 -r ts-node/register tests/**/*.spec.ts","build":"tsc","clean":"npx rimraf .nyc_output coverage/lcov* test-results.xml","debug":"npx nodemon --exec 'ts-node' local/debug.ts","test:debug":"npx mocha --inspect=0.0.0.0:9230 --opts mocha.opts","test:watch":"npx mocha --opts mocha.opts --watch","test:coverage":"npm run clean ; npx nyc --reporter=lcov mocha --opts mocha.opts && sed -i 's/\\/home\\/node\\/kafka-client\\//\\.\\//g' coverage/lcov.info","prepublishOnly":"npm run build","start:debug:ts":"npx nodemon --config nodemon-debug.json","upload-coverage":"cat ./coverage/lcov.info | npx coveralls","test:watch:debug":"npx mocha --inspect=0.0.0.0:9230 --opts mocha.opts --watch","start:debug:ts:brk":"node --inspect-brk --require ts-node/register index.ts"},"_npmUser":{"name":"kaputse","email":"denbuec@gmail.com"},"deprecated":"Consider using vanilla KafkaJS instead. This library is not used, not maintained for a long time and has several serious limitations including autocommit (for highly reliable systems you probably prefer better protection from lost messages), execution of consumers in separate calls (making it more difficult to handle full batch together for bound messages), lack of solid documentation and possibly hiding some kafkajs interfaces from you","repository":{"url":"git+https://github.com/OpusCapita/kafka-client.git","type":"git"},"_npmVersion":"5.4.2","description":"OpusCapita kafka client library.","directories":{},"_nodeVersion":"6.1.0","dependencies":{"extend":"^3.0.2","kafkajs":"^1.9.3","ocbesbn-logger":"^1.0.11","@opuscapita/config":"^3.0.16"},"_hasShrinkwrap":false,"devDependencies":{"nyc":"^11.9.0","chai":"^4.2.0","mocha":"^6.1.4","rimraf":"^2.6.2","ts-node":"^8.3.0","typedoc":"^0.14.2","typescript":"^3.5.3","@types/chai":"^4.1.7","@types/node":"^12.6.2","@types/mocha":"^5.2.7","@types/extend":"^3.0.1","@types/kafkajs":"^1.8.2","source-map-support":"^0.5.12","typedoc-plugin-markdown":"^2.0.8","@istanbuljs/nyc-config-typescript":"^0.1.3"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_1.0.4_1563950192647_0.6732392278060639","host":"s3://npm-registry-packages"}},"1.0.5":{"name":"@opuscapita/kafka-client","version":"1.0.5","keywords":[],"author":"","license":"ISC","_id":"@opuscapita/kafka-client@1.0.5","maintainers":[{"name":"adam-dziomdziora-cybercom","email":"adam.dziomdziora@cybercom.com"},{"name":"alexanderdanilov","email":"adanilov@scand.com"},{"name":"alexeysergeev","email":"sab@scand.com"},{"name":"amourzenkov-sc","email":"andrei.mourzenkov@opuscapita.com"},{"name":"bo-kh","email":"boris.khorosh@gmail.com"},{"name":"dmitrydivin","email":"divin.dmitry@gmail.com"},{"name":"dsanko","email":"dsanko@scand.com"},{"name":"egor.stambakio","email":"egor.stambakio@opuscapita.com"},{"name":"elefantino","email":"net.tyumen@mail.ru"},{"name":"eriihine","email":"esa.riihinen@gmail.com"},{"name":"gr4per","email":"arne.graeper@opuscapita.com"},{"name":"havantkim","email":"kimmo.havantola@opuscapita.com"},{"name":"ilkkalehtinen","email":"ilkka.lehtinen@opuscapita.com"},{"name":"janek.bug","email":"janek.bug@gmail.com"},{"name":"jenni","email":"jenni.ristonmaa@gmail.com"},{"name":"jluukka","email":"joel.luukka@opuscapita.com"},{"name":"kaputse","email":"denbuec@gmail.com"},{"name":"kirillvolkovich","email":"kirill.volkovich@opuscapita.com"},{"name":"kwierchris","email":"christian.drengenberg@opuscapita.com"},{"name":"lukaszkepa","email":"lke.kemps@gmail.com"},{"name":"naniantero","email":"jani@geniem.com"},{"name":"nczeranka","email":"norbert.czeranka@opuscapita.com"},{"name":"nkovalenko-sc","email":"nikolai.kovalenko@opuscapita.com"},{"name":"ocmachineuser","email":"pim.machineuser@opuscapita.com"},{"name":"pdetmer","email":"detmerpiotr@gmail.com"},{"name":"samikarj","email":"samikarj@gmail.com"},{"name":"tamkov-sc","email":"tamkov@scand.com"},{"name":"zjuice","email":"juhani.lindfors@opuscapita.com"}],"homepage":"https://github.com/OpusCapita/kafka-client#readme","bugs":{"url":"https://github.com/OpusCapita/kafka-client/issues"},"dist":{"shasum":"79ef40460e3fdbff41fdae630152a36996a2a031","tarball":"https://registry.npmjs.org/@opuscapita/kafka-client/-/kafka-client-1.0.5.tgz","fileCount":47,"integrity":"sha512-VbPPcCLXtp22kU2Pre8dxhByXGfWOtLxDDwalQn/Y7oHqZYRbfYP5I73OxtbEkm5YYOvO4eDBxBf4ArfFvsCkg==","signatures":[{"sig":"MEUCIDXJojeewZWEBTR9sIr8pHMYpe9E0fVxcso64yhSC2KNAiEAz4Rj+xeQHoWudxNLJSERY78jZCC4NXCvF8nxMaLG+AI=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":127938,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJdOA4gCRA9TVsSAnZWagAAuf8QAJgF+4b60imvSLZb3NVu\n5NzOBU/wyjAVUw5Amm+qL+hBFUB/J9gCG0msAVWJkR8wZhKy8QZTHBeXxVL8\nf4S25g0Bhs8S0HKa4MldXE9wTIhP7F5Gde99ZIDbfyZiHxeIBxQWFEngZLX3\nArdXRzd4KruWMflX4R3jqP+IpTzy3oKGmtDEZ+MkZqzURUFrur89hFOhmmah\nqwOUDqfWCFLwLJFgzPWksRQqc9m9e3cEBSSZOkCe2eq6xMobgcLfg3oFpaXw\nHi7SiDU/LP5QBATInNT5qnBgiBMfqH+6/ztTh3UdjfYqfLGjMqInS5OR52cu\nSbwvL3Q+qyFedu6FBpkqEx7/99z5l1Y/Y7uIqMgrP7wT3ynzV2U8ewmppxsq\nFn59ZDlyUlhg2gZD9sAhEZoNbn/SKfKKXVRTAnjMbwnBwDatmoWFkFUJaU1Y\ngPsHWQEgd4sNFFAfIPGJ672ynCbkARzN0hvOrtJSvVPbLlWEexa3DEa5vulH\nxxKxI7NiAlsqT/BZG0pfQGvat+XHnUXOvFIc2qbPR+7Jl63EdvKCSWdZTUzu\njdphdVl3eXa9Mp2MnWpS6JqzsYyyHi4fZFXcbM3LZJxLmLn4siJnYT62oP/Z\n3LP7f3A4tlqel81aLgyIzUQTyLfs44IKoQLbvRJEfnhJ4vY42Wj2wBapJzrZ\nr6He\r\n=3QYb\r\n-----END PGP SIGNATURE-----\r\n"},"main":"dist/index.js","gitHead":"1bdff85dccd70b1bd249ddb5cba8b93f2c78966e","scripts":{"dev":"npx nodemon","test":"npx mocha --timeout 120000 -r ts-node/register tests/**/*.spec.ts","build":"tsc","clean":"npx rimraf .nyc_output coverage/lcov* test-results.xml","debug":"npx nodemon --exec 'ts-node' local/debug.ts","test:debug":"npx mocha --inspect=0.0.0.0:9230 --opts mocha.opts","test:watch":"npx mocha --opts mocha.opts --watch","test:coverage":"npm run clean ; npx nyc --reporter=lcov mocha --opts mocha.opts && sed -i 's/\\/home\\/node\\/kafka-client\\//\\.\\//g' coverage/lcov.info","prepublishOnly":"npm run build","start:debug:ts":"npx nodemon --config nodemon-debug.json","upload-coverage":"cat ./coverage/lcov.info | npx coveralls","test:watch:debug":"npx mocha --inspect=0.0.0.0:9230 --opts mocha.opts --watch","start:debug:ts:brk":"node --inspect-brk --require ts-node/register index.ts"},"_npmUser":{"name":"kaputse","email":"denbuec@gmail.com"},"deprecated":"Consider using vanilla KafkaJS instead. This library is not used, not maintained for a long time and has several serious limitations including autocommit (for highly reliable systems you probably prefer better protection from lost messages), execution of consumers in separate calls (making it more difficult to handle full batch together for bound messages), lack of solid documentation and possibly hiding some kafkajs interfaces from you","repository":{"url":"git+https://github.com/OpusCapita/kafka-client.git","type":"git"},"_npmVersion":"5.4.2","description":"OpusCapita kafka client library.","directories":{},"_nodeVersion":"6.1.0","dependencies":{"extend":"^3.0.2","kafkajs":"^1.9.3","ocbesbn-logger":"^1.0.11","@opuscapita/config":"^3.0.16"},"_hasShrinkwrap":false,"devDependencies":{"nyc":"^11.9.0","chai":"^4.2.0","mocha":"^6.1.4","rimraf":"^2.6.2","ts-node":"^8.3.0","typedoc":"^0.14.2","typescript":"^3.5.3","@types/chai":"^4.1.7","@types/node":"^12.6.2","@types/mocha":"^5.2.7","@types/extend":"^3.0.1","@types/kafkajs":"^1.8.2","source-map-support":"^0.5.12","typedoc-plugin-markdown":"^2.0.8","@istanbuljs/nyc-config-typescript":"^0.1.3"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_1.0.5_1563954719684_0.027448659648010132","host":"s3://npm-registry-packages"}},"1.0.6":{"name":"@opuscapita/kafka-client","version":"1.0.6","keywords":[],"author":"","license":"ISC","_id":"@opuscapita/kafka-client@1.0.6","maintainers":[{"name":"adam-dziomdziora-cybercom","email":"adam.dziomdziora@cybercom.com"},{"name":"alexanderdanilov","email":"adanilov@scand.com"},{"name":"alexeysergeev","email":"sab@scand.com"},{"name":"amourzenkov-sc","email":"andrei.mourzenkov@opuscapita.com"},{"name":"bo-kh","email":"boris.khorosh@gmail.com"},{"name":"dmitrydivin","email":"divin.dmitry@gmail.com"},{"name":"dsanko","email":"dsanko@scand.com"},{"name":"egor.stambakio","email":"egor.stambakio@opuscapita.com"},{"name":"elefantino","email":"net.tyumen@mail.ru"},{"name":"eriihine","email":"esa.riihinen@gmail.com"},{"name":"gr4per","email":"arne.graeper@opuscapita.com"},{"name":"havantkim","email":"kimmo.havantola@opuscapita.com"},{"name":"ilkkalehtinen","email":"ilkka.lehtinen@opuscapita.com"},{"name":"janek.bug","email":"janek.bug@gmail.com"},{"name":"jenni","email":"jenni.ristonmaa@gmail.com"},{"name":"jluukka","email":"joel.luukka@opuscapita.com"},{"name":"kaputse","email":"denbuec@gmail.com"},{"name":"kirillvolkovich","email":"kirill.volkovich@opuscapita.com"},{"name":"kwierchris","email":"christian.drengenberg@opuscapita.com"},{"name":"lukaszkepa","email":"lke.kemps@gmail.com"},{"name":"naniantero","email":"jani@geniem.com"},{"name":"nczeranka","email":"norbert.czeranka@opuscapita.com"},{"name":"nkovalenko-sc","email":"nikolai.kovalenko@opuscapita.com"},{"name":"ocmachineuser","email":"pim.machineuser@opuscapita.com"},{"name":"pdetmer","email":"detmerpiotr@gmail.com"},{"name":"samikarj","email":"samikarj@gmail.com"},{"name":"tamkov-sc","email":"tamkov@scand.com"},{"name":"zjuice","email":"juhani.lindfors@opuscapita.com"}],"homepage":"https://github.com/OpusCapita/kafka-client#readme","bugs":{"url":"https://github.com/OpusCapita/kafka-client/issues"},"dist":{"shasum":"b19c39b6178d573a00f16789b13110f059f0ccae","tarball":"https://registry.npmjs.org/@opuscapita/kafka-client/-/kafka-client-1.0.6.tgz","fileCount":47,"integrity":"sha512-6hGlRKtEEpN4uRuGB1VHVF7RfCIGi0H5RNxdqaHP35FZALqT36kXb+Y/RGR2w/vR4tF4pW0E5oi2Kh3wnkB2jA==","signatures":[{"sig":"MEYCIQDEKWZ349WDBYbAHUe9w66uqx33cWyz6e8gNbOhYsv+/gIhALuP70+VMlKh50uKul3sedDp8dbJMtvYBOQmBBJkiPS7","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":128450,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJdOCsjCRA9TVsSAnZWagAAv5AP/j/56tcfrNsK9gunV8D/\nMFHb0c0zuE7ptbU3DlZPd3xfa8mP66iuUJU0gN32ypoR7bBD/19yBTD3LVoG\n1ZXzbXL0e8Y3LMp3pnV6xQOP0CMKDwi62D8+MRzt79YorPUxETnBvnt0h8oA\nKPpYJ4Dv0yaDVl6b5mXKUbLPU0QI3gcZl17s1+51B0XAMBVUSsfy3/Ik3g+w\nPWsZDofDPt0qB7A1q4jCAHHwsywOcSKrBfAR8CMu21Sso1QqoYRIwTKrvptk\nASbwpJQXAx9mfyDNkMMxxsNj7DIDH0i55l2+FsXq4ebO6lx0nqi/rP6OdIAW\nKPutepO1C3Hr1tfvoAmxj6jTVVDvMJwoszCEs0X9SH3L6ZyPym1blTmuN3d5\nJOv460vicEpDwUYx5bC/C0Aipd/h7n9tCMcmeAvVNJluwJEEtcbPlhnrFEV/\nggeuBPvm9eqSGDg09Fq9VRdFUpVGGlofa4fnum/jv0MOeVm2Nmjw8FAj7ahx\nZmLkcFoqp38j3IxnEUSw8QfPgf/myYwmO/+ITbkLLaNyT3rvQZGPBAaQQ/G8\nPDv2nYlxr4NDMe/3WQKauNYC6ellRnlauaogASzwnulQVl1NmVdpL3zTh+YV\nm/8v72HJsdaicj1qxNf/M1tNCaXDWgFh8xJw+xvJMJYiZYvGvirPRtm2TSJw\nUVs6\r\n=mkpa\r\n-----END PGP SIGNATURE-----\r\n"},"main":"dist/index.js","gitHead":"cc7e77280cc3289f80bda017dfc5995582ec361d","scripts":{"dev":"npx nodemon","test":"npx mocha --timeout 120000 -r ts-node/register tests/**/*.spec.ts","build":"tsc","clean":"npx rimraf .nyc_output coverage/lcov* test-results.xml","debug":"npx nodemon --exec 'ts-node' local/debug.ts","test:debug":"npx mocha --inspect=0.0.0.0:9230 --opts mocha.opts","test:watch":"npx mocha --opts mocha.opts --watch","test:coverage":"npm run clean ; npx nyc --reporter=lcov mocha --opts mocha.opts && sed -i 's/\\/home\\/node\\/kafka-client\\//\\.\\//g' coverage/lcov.info","prepublishOnly":"npm run build","start:debug:ts":"npx nodemon --config nodemon-debug.json","upload-coverage":"cat ./coverage/lcov.info | npx coveralls","test:watch:debug":"npx mocha --inspect=0.0.0.0:9230 --opts mocha.opts --watch","start:debug:ts:brk":"node --inspect-brk --require ts-node/register index.ts"},"_npmUser":{"name":"kaputse","email":"denbuec@gmail.com"},"deprecated":"Consider using vanilla KafkaJS instead. This library is not used, not maintained for a long time and has several serious limitations including autocommit (for highly reliable systems you probably prefer better protection from lost messages), execution of consumers in separate calls (making it more difficult to handle full batch together for bound messages), lack of solid documentation and possibly hiding some kafkajs interfaces from you","repository":{"url":"git+https://github.com/OpusCapita/kafka-client.git","type":"git"},"_npmVersion":"5.4.2","description":"OpusCapita kafka client library.","directories":{},"_nodeVersion":"6.1.0","dependencies":{"extend":"^3.0.2","kafkajs":"^1.9.3","ocbesbn-logger":"^1.0.11","@opuscapita/config":"^3.0.16"},"_hasShrinkwrap":false,"devDependencies":{"nyc":"^11.9.0","chai":"^4.2.0","mocha":"^6.1.4","rimraf":"^2.6.2","ts-node":"^8.3.0","typedoc":"^0.14.2","typescript":"^3.5.3","@types/chai":"^4.1.7","@types/node":"^12.6.2","@types/mocha":"^5.2.7","@types/extend":"^3.0.1","@types/kafkajs":"^1.8.2","source-map-support":"^0.5.12","typedoc-plugin-markdown":"^2.0.8","@istanbuljs/nyc-config-typescript":"^0.1.3"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_1.0.6_1563962146437_0.8146882412568746","host":"s3://npm-registry-packages"}},"1.0.7":{"name":"@opuscapita/kafka-client","version":"1.0.7","keywords":[],"author":"","license":"ISC","_id":"@opuscapita/kafka-client@1.0.7","maintainers":[{"name":"adam-dziomdziora-cybercom","email":"adam.dziomdziora@cybercom.com"},{"name":"alexanderdanilov","email":"adanilov@scand.com"},{"name":"alexeysergeev","email":"sab@scand.com"},{"name":"amourzenkov-sc","email":"andrei.mourzenkov@opuscapita.com"},{"name":"bo-kh","email":"boris.khorosh@gmail.com"},{"name":"dmitrydivin","email":"divin.dmitry@gmail.com"},{"name":"dsanko","email":"dsanko@scand.com"},{"name":"egor.stambakio","email":"egor.stambakio@opuscapita.com"},{"name":"elefantino","email":"net.tyumen@mail.ru"},{"name":"eriihine","email":"esa.riihinen@gmail.com"},{"name":"gr4per","email":"arne.graeper@opuscapita.com"},{"name":"havantkim","email":"kimmo.havantola@opuscapita.com"},{"name":"ilkkalehtinen","email":"ilkka.lehtinen@opuscapita.com"},{"name":"janek.bug","email":"janek.bug@gmail.com"},{"name":"jenni","email":"jenni.ristonmaa@gmail.com"},{"name":"jluukka","email":"joel.luukka@opuscapita.com"},{"name":"kaputse","email":"denbuec@gmail.com"},{"name":"kirillvolkovich","email":"kirill.volkovich@opuscapita.com"},{"name":"kwierchris","email":"christian.drengenberg@opuscapita.com"},{"name":"lukaszkepa","email":"lke.kemps@gmail.com"},{"name":"naniantero","email":"jani@geniem.com"},{"name":"nczeranka","email":"norbert.czeranka@opuscapita.com"},{"name":"nkovalenko-sc","email":"nikolai.kovalenko@opuscapita.com"},{"name":"ocmachineuser","email":"pim.machineuser@opuscapita.com"},{"name":"pdetmer","email":"detmerpiotr@gmail.com"},{"name":"samikarj","email":"samikarj@gmail.com"},{"name":"tamkov-sc","email":"tamkov@scand.com"},{"name":"zjuice","email":"juhani.lindfors@opuscapita.com"}],"homepage":"https://github.com/OpusCapita/kafka-client#readme","bugs":{"url":"https://github.com/OpusCapita/kafka-client/issues"},"dist":{"shasum":"d4e1593270a6a3a153fbbca15efa51d3e831f8ad","tarball":"https://registry.npmjs.org/@opuscapita/kafka-client/-/kafka-client-1.0.7.tgz","fileCount":50,"integrity":"sha512-lsgrV6UdRFW8IPg+hT44Tos9Nq53QSmUXs6+pW6Wx3BBEO6xcJNf99bIldKmHke5GaMv8tADYjTj3TNUsA0xXQ==","signatures":[{"sig":"MEUCIGV37+zC5qCBtxvdYMeQ8lkxVJpqyM/VPSoyciwy9sskAiEA9Ckp4MaxtdsnTQZQfy+2Fvp3gvGv0aUqANrw8bapsHg=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":136910,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJdPuSQCRA9TVsSAnZWagAAfKcP/2XR1RUlbUpqXMEpGE24\noOUUpj8mtJO+qHgF28lRnf2qI+8ADj0EVGLMLOHJnKDmyr5MpYcLk10iTq9I\nJQZwQZcLrjjR5tJDTrXNn9K1E8QIJUHSi3LkNhjvzNqA47XZW/nEn1JK9nTk\n58uckUFdMWSV5nI2Z6Q8VA/AfGQRkzB9dEH3s7dWkFsyYJsOSkFJsw1WAmc1\nqX01tXNcI2BRj3tIu7x+/dqUEb1Y7vLzgrjFxMwwvSda67+ZUc2ruQ4R6TeR\nQS+roGOcps6mS26nKupco1gSm3kgtJr82Eve1+etL3oTCfObx9o95y21tVDq\nUwi1rjcEmIG3rGrAGa3OjCbcS+f4kXDxPPBwLal0K+TQuan2hdPVdsvhSpAB\nBTOrBJPK2sAGHD7gF0AV3Li8jtwpdU50ZYYE2p7ZOmZbSJ+147bzT9bvpT9b\nvbpR7M/8fGLSQctuI+lxsz8K/OrL2PfjiRk4sVjVU/WjzA0LN1r0h4Gim9o5\n7TgqznnDY7QwuHpgxGff6Jg5kY7JOTrAJcgE1qyFRwtYjfpFbb6/xluFCVjL\nhL39ug5Wgm0kGNfVK39AThccVCmIyvaT56pENb/pxjICvrQvHqaxAzAHKWem\nIlkARAOu1ejFPZMVBkoCGjGsLtpE2PueyrhGlxugR1osNP9QEte7QaFB+MS7\nMf2A\r\n=+x7Z\r\n-----END PGP SIGNATURE-----\r\n"},"main":"dist/index.js","gitHead":"597596d4ddc4f6695c5f8784497cc542836459da","scripts":{"dev":"npx nodemon","test":"npx mocha --timeout 120000 -r ts-node/register tests/**/*.spec.ts","build":"tsc","clean":"npx rimraf .nyc_output coverage/lcov* test-results.xml","debug":"npx nodemon --exec 'ts-node' local/debug.ts","test:debug":"npx mocha --inspect=0.0.0.0:9230 --opts mocha.opts","test:watch":"npx mocha --opts mocha.opts --watch","test:coverage":"npm run clean ; npx nyc --reporter=lcov mocha --opts mocha.opts && sed -i 's/\\/home\\/node\\/kafka-client\\//\\.\\//g' coverage/lcov.info","prepublishOnly":"npm run build","start:debug:ts":"npx nodemon --config nodemon-debug.json","upload-coverage":"cat ./coverage/lcov.info | npx coveralls","test:watch:debug":"npx mocha --inspect=0.0.0.0:9230 --opts mocha.opts --watch","start:debug:ts:brk":"node --inspect-brk --require ts-node/register index.ts"},"_npmUser":{"name":"kaputse","email":"denbuec@gmail.com"},"deprecated":"Consider using vanilla KafkaJS instead. This library is not used, not maintained for a long time and has several serious limitations including autocommit (for highly reliable systems you probably prefer better protection from lost messages), execution of consumers in separate calls (making it more difficult to handle full batch together for bound messages), lack of solid documentation and possibly hiding some kafkajs interfaces from you","repository":{"url":"git+https://github.com/OpusCapita/kafka-client.git","type":"git"},"_npmVersion":"5.4.2","description":"OpusCapita kafka client library.","directories":{},"_nodeVersion":"6.1.0","dependencies":{"extend":"^3.0.2","kafkajs":"^1.9.3","ocbesbn-logger":"^1.0.11","@opuscapita/config":"^3.0.16"},"_hasShrinkwrap":false,"devDependencies":{"nyc":"^11.9.0","chai":"^4.2.0","mocha":"^6.1.4","rimraf":"^2.6.2","ts-node":"^8.3.0","typedoc":"^0.14.2","typescript":"^3.5.3","@types/chai":"^4.1.7","@types/node":"^12.6.2","@types/mocha":"^5.2.7","@types/extend":"^3.0.1","@types/kafkajs":"^1.8.2","source-map-support":"^0.5.12","typedoc-plugin-markdown":"^2.0.8","@istanbuljs/nyc-config-typescript":"^0.1.3"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_1.0.7_1564402831820_0.9120617020134847","host":"s3://npm-registry-packages"}},"1.0.8":{"name":"@opuscapita/kafka-client","version":"1.0.8","keywords":[],"author":"","license":"ISC","_id":"@opuscapita/kafka-client@1.0.8","maintainers":[{"name":"adam-dziomdziora-cybercom","email":"adam.dziomdziora@cybercom.com"},{"name":"alexanderdanilov","email":"adanilov@scand.com"},{"name":"alexeysergeev","email":"sab@scand.com"},{"name":"amourzenkov-sc","email":"andrei.mourzenkov@opuscapita.com"},{"name":"bo-kh","email":"boris.khorosh@gmail.com"},{"name":"dmitriy.sanko","email":"dmitriy.sanko@opuscapita.com"},{"name":"dmitrydivin","email":"divin.dmitry@gmail.com"},{"name":"dsanko","email":"dsanko@scand.com"},{"name":"egor.stambakio","email":"egor.stambakio@opuscapita.com"},{"name":"elefantino","email":"net.tyumen@mail.ru"},{"name":"eriihine","email":"esa.riihinen@gmail.com"},{"name":"gr4per","email":"arne.graeper@opuscapita.com"},{"name":"havantkim","email":"kimmo.havantola@opuscapita.com"},{"name":"ilkkalehtinen","email":"ilkka.lehtinen@opuscapita.com"},{"name":"janek.bug","email":"janek.bug@gmail.com"},{"name":"jenni","email":"jenni.ristonmaa@gmail.com"},{"name":"jluukka","email":"joel.luukka@opuscapita.com"},{"name":"kaputse","email":"denbuec@gmail.com"},{"name":"kirillvolkovich","email":"kirill.volkovich@opuscapita.com"},{"name":"kwierchris","email":"christian.drengenberg@opuscapita.com"},{"name":"lukaszkepa","email":"lke.kemps@gmail.com"},{"name":"naniantero","email":"jani@geniem.com"},{"name":"nczeranka","email":"norbert.czeranka@opuscapita.com"},{"name":"nkovalenko-sc","email":"nikolai.kovalenko@opuscapita.com"},{"name":"ocmachineuser","email":"pim.machineuser@opuscapita.com"},{"name":"pdetmer","email":"detmerpiotr@gmail.com"},{"name":"samikarj","email":"samikarj@gmail.com"},{"name":"tamkov-sc","email":"tamkov@scand.com"},{"name":"zjuice","email":"juhani.lindfors@opuscapita.com"}],"homepage":"https://github.com/OpusCapita/kafka-client#readme","bugs":{"url":"https://github.com/OpusCapita/kafka-client/issues"},"dist":{"shasum":"f9b30732073787704e65ffd60b8c68017d71d2bb","tarball":"https://registry.npmjs.org/@opuscapita/kafka-client/-/kafka-client-1.0.8.tgz","fileCount":50,"integrity":"sha512-zNX2jPdCAlIwDs8McbD599rz9NVzSTbgCOtk+R4R1W2fQrkbkSssFwUOeeVif2EmG4YmMVrSW0jPxhvthqzXCg==","signatures":[{"sig":"MEUCIQCDFRTj4zDYzicVHzCLsPpghcdvHSZlfjZy8H7flUgOKAIgYtziakjeN8rebhSnxSpeD9EqQZWqbS9QK/ScE5pqpV4=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":136909,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJdTRbNCRA9TVsSAnZWagAA/WgP/2NwQNviBdb8GsO39aip\n9nPxF6bvV6rLT5KPlYHBbonSer0oOgHnYu+DrumqQgvEqvzHS90xx3vkbhuo\nmF1YSVmGnxCEjTt5af1rxdo3/hpjLJZPNP5qUnkA0z65RW81KEpqt6nymReA\noJ2I697P0sF49XP9vnP8hQkc9lQuMOALFU1Bux+OW0JX2kfTP69yIdAMJ+Ye\ngMfFEXWq5n52deXvOak8dyzXx/Pkn5gruC6G4TG5cJS32JwsUuqS6HkCnUxJ\nXZpZyTsGGzP5UppMTK5liJQFfevZEplISYQyYl7om8yHn3c3Kl1qJoBzgwSM\neYpKY26N2t97iQ51BbxEQhAqNb45y0E+YFdwRsTwIC1VIBKAHw1hsHe56EFX\nyKGRgbrYnUPfRyaXCV/o9W7HU4OhzIBbE1k0zWEDjJ16aVTD+sQmsUFCwXjo\n3DHda8VGDF9wLBz3F8xI30ePijpmByHQmaFTuXMEfLUHwDY5SHZigyaR0XYX\nXv6J0TXNK6q3qyh/7yeXRfUG+5tDgvm9ByrHhdeQoPdN8PcA1sAWrpwL7jdT\nkIXSCh7Ly2zIStwjWZc5L/xCrglPH/JLvurA7sNjgFFu5v+OoAWy1YJ6w+cD\nfvlh6X0rNcOHZCRWypbkgiEg5ER+PflNspru0hb7zTrzauL+cQ2nFN8oh9+Z\n06Aw\r\n=fJzl\r\n-----END PGP SIGNATURE-----\r\n"},"main":"dist/index.js","gitHead":"860eef10e78c2ec380ad99a333e1abe105e9a297","scripts":{"dev":"npx nodemon","test":"npx mocha --timeout 120000 -r ts-node/register tests/**/*.spec.ts","build":"tsc","clean":"npx rimraf .nyc_output coverage/lcov* test-results.xml","debug":"npx nodemon --exec 'ts-node' local/debug.ts","test:debug":"npx mocha --inspect=0.0.0.0:9230 --opts mocha.opts","test:watch":"npx mocha --opts mocha.opts --watch","test:coverage":"npm run clean ; npx nyc --reporter=lcov mocha --opts mocha.opts && sed -i 's/\\/home\\/node\\/kafka-client\\//\\.\\//g' coverage/lcov.info","prepublishOnly":"npm run build","start:debug:ts":"npx nodemon --config nodemon-debug.json","upload-coverage":"cat ./coverage/lcov.info | npx coveralls","test:watch:debug":"npx mocha --inspect=0.0.0.0:9230 --opts mocha.opts --watch","start:debug:ts:brk":"node --inspect-brk --require ts-node/register index.ts"},"_npmUser":{"name":"kaputse","email":"denbuec@gmail.com"},"deprecated":"Consider using vanilla KafkaJS instead. This library is not used, not maintained for a long time and has several serious limitations including autocommit (for highly reliable systems you probably prefer better protection from lost messages), execution of consumers in separate calls (making it more difficult to handle full batch together for bound messages), lack of solid documentation and possibly hiding some kafkajs interfaces from you","repository":{"url":"git+https://github.com/OpusCapita/kafka-client.git","type":"git"},"_npmVersion":"5.4.2","description":"OpusCapita kafka client library.","directories":{},"_nodeVersion":"6.1.0","dependencies":{"extend":"^3.0.2","kafkajs":"^1.10.0","ocbesbn-logger":"^1.0.11","@opuscapita/config":"^3.0.16"},"_hasShrinkwrap":false,"devDependencies":{"nyc":"^11.9.0","chai":"^4.2.0","mocha":"^6.2.0","rimraf":"^2.6.2","ts-node":"^8.3.0","typedoc":"^0.14.2","typescript":"^3.5.3","@types/chai":"^4.1.7","@types/node":"^12.7.1","@types/mocha":"^5.2.7","@types/extend":"^3.0.1","@types/kafkajs":"^1.8.2","source-map-support":"^0.5.13","typedoc-plugin-markdown":"^2.1.1","@istanbuljs/nyc-config-typescript":"^0.1.3"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_1.0.8_1565333196699_0.19131752645993405","host":"s3://npm-registry-packages"}},"1.0.10":{"name":"@opuscapita/kafka-client","version":"1.0.10","keywords":[],"author":"","license":"ISC","_id":"@opuscapita/kafka-client@1.0.10","maintainers":[{"name":"adam-dziomdziora-cybercom","email":"adam.dziomdziora@cybercom.com"},{"name":"alexanderdanilov","email":"adanilov@scand.com"},{"name":"alexeysergeev","email":"sab@scand.com"},{"name":"amourzenkov-sc","email":"andrei.mourzenkov@opuscapita.com"},{"name":"bo-kh","email":"boris.khorosh@gmail.com"},{"name":"dmitriy.sanko","email":"dmitriy.sanko@opuscapita.com"},{"name":"dmitrydivin","email":"divin.dmitry@gmail.com"},{"name":"dsanko","email":"dsanko@scand.com"},{"name":"egor.stambakio","email":"egor.stambakio@opuscapita.com"},{"name":"elefantino","email":"net.tyumen@mail.ru"},{"name":"eriihine","email":"esa.riihinen@gmail.com"},{"name":"gr4per","email":"arne.graeper@opuscapita.com"},{"name":"havantkim","email":"kimmo.havantola@opuscapita.com"},{"name":"ilkkalehtinen","email":"ilkka.lehtinen@opuscapita.com"},{"name":"janek.bug","email":"janek.bug@gmail.com"},{"name":"jenni","email":"jenni.ristonmaa@gmail.com"},{"name":"jluukka","email":"joel.luukka@opuscapita.com"},{"name":"kaputse","email":"denbuec@gmail.com"},{"name":"kirillvolkovich","email":"kirill.volkovich@opuscapita.com"},{"name":"kwierchris","email":"christian.drengenberg@opuscapita.com"},{"name":"lukaszkepa","email":"lke.kemps@gmail.com"},{"name":"naniantero","email":"jani@geniem.com"},{"name":"nczeranka","email":"norbert.czeranka@opuscapita.com"},{"name":"nkovalenko-sc","email":"nikolai.kovalenko@opuscapita.com"},{"name":"ocmachineuser","email":"pim.machineuser@opuscapita.com"},{"name":"pdetmer","email":"detmerpiotr@gmail.com"},{"name":"samikarj","email":"samikarj@gmail.com"},{"name":"tamkov-sc","email":"tamkov@scand.com"},{"name":"zjuice","email":"juhani.lindfors@opuscapita.com"}],"homepage":"https://github.com/OpusCapita/kafka-client#readme","bugs":{"url":"https://github.com/OpusCapita/kafka-client/issues"},"dist":{"shasum":"f2b6a2cc3f8e50f8c8a1c06a8f3f09eb7eec6892","tarball":"https://registry.npmjs.org/@opuscapita/kafka-client/-/kafka-client-1.0.10.tgz","fileCount":50,"integrity":"sha512-J5p6B/HCVsnrd/DdGNtVU18LU0wEs1Ny5H4ylbe8dhokzJ7BWb0FcY5Lvrke67oGn0xkazvPlaIZ6ADazRVP5g==","signatures":[{"sig":"MEQCIHvpG3NtgAmhjBCHW2RiKnxRk/94QQCqlF35xfFGBuP1AiALuOdJVsZfPfKJxUIZHKjdrSKIq65nGsevaLOTd/yy9g==","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":141383,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJdZ9QkCRA9TVsSAnZWagAAZPgP/3M2AQEVLcPvUqS6g5Tu\nhupth8iMedCyTZDx2Ap0hsWDqwLQY3oc+PB0WPUcC56CzFQBNpXTAb8MaO/w\n9TXNsIqyxRqeLx+0xSBAOn7k5JBV8S1PHkeOuUa5Nme/R3M/e5/0Wfk/zP27\nZfBRRysAdsUcucXK0s3gOo8IUcILVrScWPzyvkSJS1gOVZH1CJNdZ26Pt+Om\nZkqpsR8CQEgdP8B7ppmK+4NnldrDie8uXd4gQAU6xCZlrDtloXVAH0axkToh\n+LtMJQg3sHbBEI/O+/EWnIunku1mAPLvA4o2VsFoD9Y+f9U/3TznMiyecFXc\nWzW0++ev8s9pxnQVZIvIsIe8z+JZzIpWzB+6pIxiA8a7C+2nOKBf1lvlRCbM\nbcXl1wtTiY3BPW6nzi3zbkzRQw0OS9q2PMnVSOUqdApylR2CmTCZcMRCMNrI\nnfUCESuyFzAUdPRcbv42Rktd/S6I+dPR/uAMQE7CDNRtOlUvn41gEg6CTHnA\nXceT0gsviyvzJGeaGHMBcYbHlulTnGCgiW/4Yu/netX2Lj3mhkT57AsYAos5\ntYz2dLZTWaOy5dNmCL9DTYt5PqhxSVZKHoKeUcGdYe55vdKgEwtWLaRpdwUS\nBL14bkm+9qZSJknKx7b2Oq25gH9OwU2iQeg1F2e/kHORn+TyQGM9n1I6rtB7\nmUdy\r\n=iPn3\r\n-----END PGP SIGNATURE-----\r\n"},"main":"dist/index.js","gitHead":"e1b4e3c18ebb6071f2df39eaa01fe041a7cc889c","scripts":{"dev":"npx nodemon","test":"npx mocha --timeout 120000 -r ts-node/register tests/**/*.spec.ts","build":"tsc","clean":"npx rimraf .nyc_output coverage/lcov* test-results.xml","debug":"npx nodemon --exec 'ts-node' local/debug.ts","test:debug":"npx mocha --inspect=0.0.0.0:9230 --opts mocha.opts","test:watch":"npx mocha --opts mocha.opts --watch","test:coverage":"npm run clean ; npx nyc --reporter=lcov mocha --opts mocha.opts && sed -i 's/\\/home\\/node\\/kafka-client\\//\\.\\//g' coverage/lcov.info","prepublishOnly":"npm run build","start:debug:ts":"npx nodemon --config nodemon-debug.json","upload-coverage":"cat ./coverage/lcov.info | npx coveralls","test:watch:debug":"npx mocha --inspect=0.0.0.0:9230 --opts mocha.opts --watch","start:debug:ts:brk":"node --inspect-brk --require ts-node/register index.ts"},"_npmUser":{"name":"kaputse","email":"denbuec@gmail.com"},"deprecated":"Consider using vanilla KafkaJS instead. This library is not used, not maintained for a long time and has several serious limitations including autocommit (for highly reliable systems you probably prefer better protection from lost messages), execution of consumers in separate calls (making it more difficult to handle full batch together for bound messages), lack of solid documentation and possibly hiding some kafkajs interfaces from you","repository":{"url":"git+https://github.com/OpusCapita/kafka-client.git","type":"git"},"_npmVersion":"5.4.2","description":"OpusCapita kafka client library.","directories":{},"_nodeVersion":"6.1.0","dependencies":{"extend":"^3.0.2","kafkajs":"^1.10.0","ocbesbn-logger":"^1.0.11","@opuscapita/config":"^3.0.16"},"_hasShrinkwrap":false,"devDependencies":{"nyc":"^11.9.0","chai":"^4.2.0","mocha":"^6.2.0","rimraf":"^2.7.1","ts-node":"^8.3.0","typedoc":"^0.14.2","typescript":"^3.6.2","@types/chai":"^4.2.0","@types/node":"^12.7.2","@types/mocha":"^5.2.7","@types/extend":"^3.0.1","@types/kafkajs":"^1.8.2","source-map-support":"^0.5.13","typedoc-plugin-markdown":"^2.1.4","@istanbuljs/nyc-config-typescript":"^0.1.3"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_1.0.10_1567085603692_0.21517521499192105","host":"s3://npm-registry-packages"}},"1.0.11":{"name":"@opuscapita/kafka-client","version":"1.0.11","keywords":[],"author":"","license":"ISC","_id":"@opuscapita/kafka-client@1.0.11","maintainers":[{"name":"maciej-wakula-opuscapita","email":"maciej.wakula@opuscapita.com"},{"name":"bo-kh","email":"boris.khorosh@gmail.com"},{"name":"pdetmer","email":"detmerpiotr@gmail.com"},{"name":"janek.bug","email":"janek.bug@gmail.com"},{"name":"alexeysergeev","email":"sab@scand.com"},{"name":"ilkkalehtinen","email":"ilkka.lehtinen@ekoti.com"},{"name":"havantkim","email":"kimmo.havantola@opuscapita.com"},{"name":"eriihine","email":"esa.riihinen@gmail.com"},{"name":"tamkov-sc","email":"tamkov@scand.com"},{"name":"kwierchris","email":"christian.drengenberg@opuscapita.com"},{"name":"elefantino","email":"net.tyumen@mail.ru"},{"name":"samikarj","email":"samikarj@gmail.com"},{"name":"dsanko","email":"dsanko@scand.com"},{"name":"dmitrydivin","email":"divin.dmitry@gmail.com"},{"name":"alexanderdanilov","email":"adanilov@scand.com"},{"name":"egor.stambakio","email":"egor.stambakio@opuscapita.com"},{"name":"jenni","email":"jenni.ristonmaa@gmail.com"},{"name":"ocmachineuser","email":"pim.machineuser@opuscapita.com"},{"name":"lukaszkepa","email":"lke.kemps@gmail.com"},{"name":"naniantero","email":"jani@geniem.com"},{"name":"nkovalenko-sc","email":"nikolai.kovalenko@opuscapita.com"},{"name":"jluukka","email":"joel.luukka@yahoo.co.uk"},{"name":"zjuice","email":"juhani.lindfors@opuscapita.com"},{"name":"adam-dziomdziora-cybercom","email":"adam.dziomdziora@cybercom.com"},{"name":"kaputse","email":"denbuec@gmail.com"},{"name":"dmitriy.sanko","email":"dmitriy.sanko@opuscapita.com"},{"name":"nczeranka","email":"norbert.czeranka@opuscapita.com"},{"name":"ocautomation","email":"ocbuildautomation@opuscapita.com"}],"homepage":"https://github.com/OpusCapita/kafka-client#readme","bugs":{"url":"https://github.com/OpusCapita/kafka-client/issues"},"dist":{"shasum":"94b52d6dc5d91ecff42c4d7c1e4ea798c96a6ec9","tarball":"https://registry.npmjs.org/@opuscapita/kafka-client/-/kafka-client-1.0.11.tgz","fileCount":53,"integrity":"sha512-gdETKFrROumMBmQ58Xr68XdV4n8M7q/cnSDIFUyOx8PEK6i1rXv32MAKuJXDXT/84mF3UqpN0kOFizwtxW8SpA==","signatures":[{"sig":"MEUCIBsc5tF3KlrBXMPvpxWi5oUsuuLRtRaKQLbDxOSLuDkhAiEA5NkA+atrRM9OazkZGTkJ+Y0f3bcdrTd9rMOFWxtiOaA=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":147248,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.13\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJg+qRrCRA9TVsSAnZWagAApqwQAJ427yNi2RvOmSMzB/ks\n97LBErjXwfjZZximjO5RmXTGyK4HVUwtFU4XXHIgFl+YWPXqRiIIm+ANm2k+\nDTR2R6HwKIMTuWJ3MAb5Dh7U1doPPgUsFvMY3wxXlvikeKZyLRPhiVYZWLZ2\n+6vNBCxAz2YanRLyur3QdSTapnalvEGWYKFQ+ukuQfDEAFOOgujTyQmIIdiL\nHcxOpUMAmed7SqMaUMdhHfoai1D6P7y3H9/B87AX+ZGIfZDt+A6UahOgQknd\nGYX+x9jcDBgrr8k0CFoIPkWnzfXgpSmgEMzQOjH6Vb/u2LO4V40WPPjPtKHp\n53tMWHJ6fDu8lD7KKmrxCoiFsRoe+Zy8aoM6HV1WPO12u6SzTrwK1eddMQKD\ng5WN4sgi/pFHDR3bTh9Ytc8HXrkgsupGcU7sefTm7Q6IVUaYHgXXAvw4FTW9\n04/S2QuaiapnNl/ciFGyipg+MClPh1IerVwA+y/T0FbOjJXW69TPR4LlqOE7\nOVrKRRvgU7KZbP4n5206HrsYcTtahI/bM1yJRCIhSlHvjv9Eu7PD3ciQVPBs\nslp1A4Civ3rrjCaM+vaMV/ogP8ho9c8WhxQpn7gudsjRdeLXoByqKxVNL//f\n389q+LCWRDJPdiEMNiVvJp8e2AtC+67aySSioaG2OUXNMqsYighyqNF/FCOD\nwCRx\r\n=Zy++\r\n-----END PGP SIGNATURE-----\r\n"},"main":"dist/index.js","gitHead":"be77cc428d06fc890e483c376b283b6e1993978d","scripts":{"dev":"npx nodemon","test":"npx mocha --timeout 120000 -r ts-node/register tests/**/*.spec.ts","build":"tsc","clean":"npx rimraf .nyc_output coverage/lcov* test-results.xml","debug":"npx nodemon --exec 'ts-node' local/debug.ts","test:debug":"npx mocha --inspect=0.0.0.0:9230 --opts mocha.opts","test:watch":"npx mocha --opts mocha.opts --watch","test:coverage":"npm run clean ; npx nyc --reporter=lcov mocha --opts mocha.opts && sed -i 's/\\/home\\/node\\/kafka-client\\//\\.\\//g' coverage/lcov.info","prepublishOnly":"npm run build","start:debug:ts":"npx nodemon --config nodemon-debug.json","upload-coverage":"cat ./coverage/lcov.info | npx coveralls","test:watch:debug":"npx mocha --inspect=0.0.0.0:9230 --opts mocha.opts --watch","start:debug:ts:brk":"node --inspect-brk --require ts-node/register index.ts"},"_npmUser":{"name":"ocautomation","email":"ocbuildautomation@opuscapita.com"},"deprecated":"Consider using vanilla KafkaJS instead. This library is not used, not maintained for a long time and has several serious limitations including autocommit (for highly reliable systems you probably prefer better protection from lost messages), execution of consumers in separate calls (making it more difficult to handle full batch together for bound messages), lack of solid documentation and possibly hiding some kafkajs interfaces from you","repository":{"url":"git+https://github.com/OpusCapita/kafka-client.git","type":"git"},"_npmVersion":"5.4.2","description":"OpusCapita kafka client library.","directories":{},"_nodeVersion":"6.1.0","dependencies":{"extend":"^3.0.2","kafkajs":"^1.12.0","@opuscapita/config":"^3.1.1","@opuscapita/logger":"^1.1.0","@kafkajs/confluent-schema-registry":"^1.0.6"},"_hasShrinkwrap":false,"devDependencies":{"nyc":"^11.9.0","chai":"^4.3.4","mocha":"^6.2.3","rimraf":"^2.7.1","ts-node":"^8.10.2","typedoc":"^0.14.2","typescript":"^3.9.10","@types/chai":"^4.2.21","@types/node":"^12.20.16","@types/mocha":"^5.2.7","@types/extend":"^3.0.1","@types/kafkajs":"^1.9.0","source-map-support":"^0.5.19","typedoc-plugin-markdown":"^2.4.2","@istanbuljs/nyc-config-typescript":"^0.1.3"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_1.0.11_1627038827511_0.9968297418052385","host":"s3://npm-registry-packages"}},"2.0.0":{"name":"@opuscapita/kafka-client","version":"2.0.0","keywords":[],"author":"","license":"ISC","_id":"@opuscapita/kafka-client@2.0.0","maintainers":[{"name":"ilhamkadduri","email":"ilham.kaddouri@opuscapita.com"},{"name":"smachnow","email":"stefan.machnow@opuscapita.com"},{"name":"piotr.krzysztof.murdzia","email":"piotr.krzysztof.murdzia@gmail.com"},{"name":"kuos","email":"kacpermklosowski@gmail.com"},{"name":"elaczapiewska","email":"elzbieta.rymarkiewicz-czapiewska@opuscapita.com"},{"name":"janek.bug","email":"janek.bug@gmail.com"},{"name":"ocmachineuser","email":"pim.machineuser@opuscapita.com"},{"name":"ocautomation","email":"ocbuildautomation@opuscapita.com"},{"name":"maciej-wakula-opuscapita","email":"maciej.wakula@opuscapita.com"}],"homepage":"https://github.com/OpusCapita/kafka-client#readme","bugs":{"url":"https://github.com/OpusCapita/kafka-client/issues"},"dist":{"shasum":"465d93979c62b7df4749a82913e9dfa62dffbd68","tarball":"https://registry.npmjs.org/@opuscapita/kafka-client/-/kafka-client-2.0.0.tgz","fileCount":71,"integrity":"sha512-VUYDAd5drGwGjgaCUK0M/b1yELFGsDuNBoxB7oZozJwb4w0O69bKZWkCOxl3KzQbEB+l/bq/yx1M2ZkXw4rVnA==","signatures":[{"sig":"MEYCIQD27VlThUKK9ZV5k9fa/3jdwpHQ2GpihMUEgYhMgSGkoQIhAKz1rtreWRRJH5UrIzvyvQ80hDi2NOxI+xxSp1PbjtU7","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":194863},"main":"dist/index.js","types":"./dist/index.d.ts","gitHead":"5606947b95295b8cf222c2d1c14bb62e8415ab0c","scripts":{"dev":"npx nodemon","test":"npm run setup:test ; npx mocha --timeout 120000 -r ts-node/register tests/**/*.spec.ts","build":"tsc","clean":"npx rimraf .nyc_output coverage/lcov* test-results.xml","setup:test":"sh setup-consul.sh","test:debug":"npx mocha --inspect=0.0.0.0:9230 --opts mocha.opts","test:watch":"npx mocha --opts mocha.opts --watch","test:coverage":"npm run clean ; npx nyc --reporter=lcov mocha --opts mocha.opts && sed -i 's/\\/home\\/node\\/kafka-client\\//\\.\\//g' coverage/lcov.info","start:debug:ts":"npx nodemon --config nodemon-debug.json","upload-coverage":"cat ./coverage/lcov.info | npx coveralls","test:watch:debug":"npx mocha --inspect=0.0.0.0:9230 --opts mocha.opts --watch","start:debug:ts:brk":"node --inspect-brk --require ts-node/register index.ts"},"_npmUser":{"name":"maciej-wakula-opuscapita","email":"maciej.wakula@opuscapita.com"},"repository":{"url":"git+https://github.com/OpusCapita/kafka-client.git","type":"git"},"_npmVersion":"8.19.4","description":"OpusCapita kafka client library.","directories":{},"_nodeVersion":"16.20.2","dependencies":{"extend":"^3.0.2","kafkajs":"^1.16.0","correlation-id":"^4.0.0","@opuscapita/config":"^3.1.13","@opuscapita/logger":"^2.1.2","@kafkajs/confluent-schema-registry":"^1.0.6"},"_hasShrinkwrap":false,"devDependencies":{"nyc":"^11.9.0","chai":"^4.3.8","mocha":"^6.2.3","rimraf":"^2.7.1","ts-node":"^8.10.2","typescript":"^3.9.10","@types/chai":"^4.3.6","@types/node":"^12.20.55","@types/mocha":"^5.2.7","@types/extend":"^3.0.2","@types/kafkajs":"^1.9.0","source-map-support":"^0.5.21","@types/correlation-id":"^2.1.2","@istanbuljs/nyc-config-typescript":"^0.1.3"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_2.0.0_1696232695046_0.9201139911995238","host":"s3://npm-registry-packages"}},"2.0.1":{"name":"@opuscapita/kafka-client","version":"2.0.1","keywords":[],"author":"","license":"ISC","_id":"@opuscapita/kafka-client@2.0.1","maintainers":[{"name":"ilhamkadduri","email":"ilham.kaddouri@opuscapita.com"},{"name":"smachnow","email":"stefan.machnow@opuscapita.com"},{"name":"piotr.krzysztof.murdzia","email":"piotr.krzysztof.murdzia@gmail.com"},{"name":"kuos","email":"kacpermklosowski@gmail.com"},{"name":"elaczapiewska","email":"elzbieta.rymarkiewicz-czapiewska@opuscapita.com"},{"name":"janek.bug","email":"janek.bug@gmail.com"},{"name":"ocmachineuser","email":"pim.machineuser@opuscapita.com"},{"name":"ocautomation","email":"ocbuildautomation@opuscapita.com"},{"name":"maciej-wakula-opuscapita","email":"maciej.wakula@opuscapita.com"}],"homepage":"https://github.com/OpusCapita/kafka-client#readme","bugs":{"url":"https://github.com/OpusCapita/kafka-client/issues"},"dist":{"shasum":"3e0d9de9b92bd3e69159239fabd06ee70c1f2ac5","tarball":"https://registry.npmjs.org/@opuscapita/kafka-client/-/kafka-client-2.0.1.tgz","fileCount":35,"integrity":"sha512-nlWSB+CyBKQA9JA6mAHNP73zDL1sfphep3ah4bvmqoWp3iTq5mkQIjiBrzagP8m+vpmusXf1TKCffkbli302FQ==","signatures":[{"sig":"MEUCIFiZUF8CC3Q6NHhH3UxmGTP1XnvrOHkKQfPuswg9ulhyAiEAxT3cyWNNLr8gjVKnmyj0Ra1rpWC2GhoZVomlHKro7QY=","keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA"}],"unpackedSize":102795},"main":"dist/index.js","gitHead":"60fc5a6e745fae250d1bfc14726f95e0543feaf1","scripts":{"dev":"npx nodemon","test":"npm run setup:test ; npx mocha --timeout 120000 -r ts-node/register tests/**/*.spec.ts","build":"tsc","clean":"npx rimraf .nyc_output coverage/lcov* test-results.xml","setup:test":"sh setup-consul.sh","test:debug":"npx mocha --inspect=0.0.0.0:9230 --opts mocha.opts","test:watch":"npx mocha --opts mocha.opts --watch","test:coverage":"npm run clean ; npx nyc --reporter=lcov mocha --opts mocha.opts && sed -i 's/\\/home\\/node\\/kafka-client\\//\\.\\//g' coverage/lcov.info","start:debug:ts":"npx nodemon --config nodemon-debug.json","upload-coverage":"cat ./coverage/lcov.info | npx coveralls","test:watch:debug":"npx mocha --inspect=0.0.0.0:9230 --opts mocha.opts --watch","start:debug:ts:brk":"node --inspect-brk --require ts-node/register index.ts"},"_npmUser":{"name":"maciej-wakula-opuscapita","email":"maciej.wakula@opuscapita.com"},"repository":{"url":"git+https://github.com/OpusCapita/kafka-client.git","type":"git"},"_npmVersion":"6.14.18","description":"OpusCapita kafka client library.","directories":{},"_nodeVersion":"14.21.3","dependencies":{"extend":"^3.0.2","kafkajs":"^2.2.4","correlation-id":"^4.0.0","@opuscapita/config":"^3.1.13","@opuscapita/logger":"^2.1.3","@kafkajs/confluent-schema-registry":"^1.0.6"},"_hasShrinkwrap":false,"devDependencies":{"nyc":"^11.9.0","chai":"^4.3.8","mocha":"^6.2.3","rimraf":"^2.7.1","ts-node":"^8.10.2","typescript":"^3.9.10","@types/chai":"^4.3.6","@types/node":"^12.20.55","@types/mocha":"^5.2.7","@types/extend":"^3.0.2","source-map-support":"^0.5.21","@types/correlation-id":"^2.1.2","@istanbuljs/nyc-config-typescript":"^0.1.3"},"_npmOperationalInternal":{"tmp":"tmp/kafka-client_2.0.1_1698222099303_0.008372773863570826","host":"s3://npm-registry-packages"}},"2.0.2":{"name":"@opuscapita/kafka-client","version":"2.0.2","description":"OpusCapita kafka client library.","main":"dist/index.js","repository":{"type":"git","url":"git+https://github.com/OpusCapita/kafka-client.git"},"scripts":{"build":"tsc","clean":"npx rimraf .nyc_output coverage/lcov* test-results.xml","dev":"npx nodemon","setup:test":"sh setup-consul.sh","test":"npm run setup:test ; npx mocha --timeout 120000 -r ts-node/register tests/**/*.spec.ts","test:debug":"npx mocha --inspect=0.0.0.0:9230 --opts mocha.opts","test:coverage":"npm run clean ; npx nyc --reporter=lcov mocha --opts mocha.opts && sed -i 's/\\/home\\/node\\/kafka-client\\//\\.\\//g' coverage/lcov.info","test:watch":"npx mocha --opts mocha.opts --watch","test:watch:debug":"npx mocha --inspect=0.0.0.0:9230 --opts mocha.opts --watch","start:debug:ts":"npx nodemon --config nodemon-debug.json","start:debug:ts:brk":"node --inspect-brk --require ts-node/register index.ts","upload-coverage":"cat ./coverage/lcov.info | npx coveralls"},"keywords":[],"author":"","license":"ISC","devDependencies":{"@istanbuljs/nyc-config-typescript":"^0.1.3","@types/chai":"^4.3.6","@types/correlation-id":"^2.1.2","@types/extend":"^3.0.2","@types/mocha":"^5.2.7","@types/node":"^12.20.55","chai":"^4.3.8","mocha":"^6.2.3","nyc":"^11.9.0","rimraf":"^2.7.1","source-map-support":"^0.5.21","ts-node":"^8.10.2","typescript":"^3.9.10"},"dependencies":{"@kafkajs/confluent-schema-registry":"^1.0.6","@opuscapita/config":"^3.1.13","@opuscapita/logger":"^2.1.3","correlation-id":"^4.0.0","extend":"^3.0.2","kafkajs":"^2.2.4"},"gitHead":"276d0447939f73c499676efb3925b788ea08b1f9","bugs":{"url":"https://github.com/OpusCapita/kafka-client/issues"},"homepage":"https://github.com/OpusCapita/kafka-client#readme","_id":"@opuscapita/kafka-client@2.0.2","_nodeVersion":"14.21.3","_npmVersion":"6.14.18","dist":{"integrity":"sha512-BM+JqhoVskDojozZI06sdklqDbgBbTTm+7boqXndd1irB2WMC7SUeHtjnIc3C1XkN3HhPi96aqLHCRQBiMazNg==","shasum":"014e2c18fba253e8b021b1577c5b50193709740e","tarball":"https://registry.npmjs.org/@opuscapita/kafka-client/-/kafka-client-2.0.2.tgz","fileCount":35,"unpackedSize":102733,"signatures":[{"keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U","sig":"MEUCIQD9d2+sOQwt2yKqk/MTNEkSqcmWtPZv3BBJhITHlIuSYQIgDPHjQPTuq6uWdyzu5aagYCZKwoRTowVBC2kK0IKdLfY="}]},"_npmUser":{"name":"elaczapiewska","email":"elzbieta.rymarkiewicz-czapiewska@opuscapita.com"},"directories":{},"maintainers":[{"name":"kuos","email":"kacpermklosowski@gmail.com"},{"name":"ocmachineuser","email":"pim.machineuser@opuscapita.com"},{"name":"elaczapiewska","email":"elzbieta.rymarkiewicz-czapiewska@opuscapita.com"},{"name":"ocautomation","email":"ocbuildautomation@opuscapita.com"},{"name":"piotr.krzysztof.murdzia","email":"piotr.krzysztof.murdzia@gmail.com"},{"name":"dsbbl","email":"domin25001@gmail.com"},{"name":"smachnow","email":"stefan.machnow@opuscapita.com"},{"name":"ilhamkadduri","email":"ilham.kaddouri@opuscapita.com"},{"name":"mblachu","email":"michal.blachu14@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages-npm-production","tmp":"tmp/kafka-client_2.0.2_1789647043152_0.5541642115499832"},"_hasShrinkwrap":false}},"time":{"created":"2019-07-08T13:35:24.213Z","modified":"2026-09-17T12:10:43.550Z","1.0.0":"2019-07-08T13:35:24.551Z","1.0.1":"2019-07-08T14:31:05.488Z","1.0.2":"2019-07-11T14:50:15.674Z","1.0.3":"2019-07-12T09:59:41.776Z","1.0.4":"2019-07-24T06:36:32.794Z","1.0.5":"2019-07-24T07:51:59.874Z","1.0.6":"2019-07-24T09:55:46.673Z","1.0.7":"2019-07-29T12:20:31.992Z","1.0.8":"2019-08-09T06:46:36.855Z","1.0.10":"2019-08-29T13:33:23.879Z","1.0.11":"2021-07-23T11:13:47.679Z","2.0.0":"2023-10-02T07:44:55.209Z","2.0.1":"2023-10-25T08:21:39.665Z","2.0.2":"2026-09-17T12:10:43.319Z"},"bugs":{"url":"https://github.com/OpusCapita/kafka-client/issues"},"license":"ISC","homepage":"https://github.com/OpusCapita/kafka-client#readme","keywords":[],"repository":{"type":"git","url":"git+https://github.com/OpusCapita/kafka-client.git"},"description":"OpusCapita kafka client library.","maintainers":[{"name":"kuos","email":"kacpermklosowski@gmail.com"},{"name":"ocmachineuser","email":"pim.machineuser@opuscapita.com"},{"name":"elaczapiewska","email":"elzbieta.rymarkiewicz-czapiewska@opuscapita.com"},{"name":"ocautomation","email":"ocbuildautomation@opuscapita.com"},{"name":"piotr.krzysztof.murdzia","email":"piotr.krzysztof.murdzia@gmail.com"},{"name":"dsbbl","email":"domin25001@gmail.com"},{"name":"smachnow","email":"stefan.machnow@opuscapita.com"},{"name":"ilhamkadduri","email":"ilham.kaddouri@opuscapita.com"},{"name":"mblachu","email":"michal.blachu14@gmail.com"}],"readme":"**DEPRECATED**\n\nYou should probably NOT be using this library for the following purposes:\n- not much value is added over kafkajs\n- many interfaces of native kafkajs are hidden\n- assumption of autocommit\n  - every message processed with a separate call (no batch processing)\n  - **autocommit could lead to data loss**\n- not used in OpusCapita\n\nHowever you might find it usable as there is a lot of logic implemented and it is using TypeScript.\nIn such a case feel free to unarchive it or fork.\n\n\n\n\nThis module implements a high-level Kafka consumer/producer. It is based on [kafkajs](https://kafka.js.org/) and adds some convenience functions on top of the provided functionallity:\n\n* Supports dead letter queing by implementing a simplified, one-stage DLQ without retry.\n* Enveloping: Every message is enriched by platform specific information (context) that is transparent to the application using kafka-client\n* Disables usage of wildcard topics\n* On-demand subscribe and unsubscribe\n* (tba) Metrics: Implement metrics for active health monitoring of client connections\n\nPlease find more information on the individual topics in the wiki.\n\n## Minimum setup\n\nFirst got to your local code directory and run:\n\n```\nnpm install @opuscapita/kafka-client\n```\n\nKafka-client uses consul for service discovery meaning you need to have access to a running **Consul server** to get your endpoint configuration for the broker. In addition, the **Kafka broker** itself is required which also has to be registered inside Consul.\n\n> The basic implementation requirements defines the naming conventions used for topics as follows: **serviceName.domainName.eventType.eventDetail**.\n\n#### Common subscription\n\nIf all this is set up, a new client connection can be created like this:\n\n```JS\nconst KafkaClient = require('@opuscapita/kafka-client');\nconst kafka = new KafkaClient();\nawait kafka.init();\n```\n\nConsuming and producing works analogous to the well-known rabbitMq-based event-client library. Attention: Wildcard subscriptions are no longer supported.\n\n```JS\n(async () =>\n{\n    // Subscribe to a channel by name.\n    await events.subscribe('my-service.my-channel', (m ) => { console.log(m); return true; });\n    await events.emit('my-service.my-channel', 'Hello, world!');\n\n    // unsubscribe from a particular key\n    await events.unsubscribe('my-service.my-channel');\n\n    // gracefully shutdown\n    await events.dispose();\n})();\n```\n\nIf the application callback provided as the second parameter provided to the `subscribe()` method, the message handling will be considered errornous and the message will be put the DLQ.\n\n#### Fetching single message\n\n**tbi**\n\n### Default configuration\n\nThe default configuration object provides hints about what the module's standard behavior is like.\n\n```JS\n{\n    serializer: JSON.stringify,\n    parser: JSON.parse,\n    serializerContentType: 'application/json',\n    parserContentType: 'application/json',\n    consumerGroupId: null,\n    enableHealthChecks: true,\n    logger: new Logger(),\n    consul: {\n        host: 'consul',\n        mqServiceName: 'kafka'\n    },\n    consulOverride: {\n        host: null\n    },\n    context: {\n    }\n}\n```\n","readmeFilename":"README.md"}