{"_id":"@3g/kafka-wrapper","_rev":"8-a2d50d55c28f115462b8436a33583d5d","name":"@3g/kafka-wrapper","dist-tags":{"latest":"2.0.4"},"versions":{"1.0.0":{"name":"@3g/kafka-wrapper","version":"1.0.0","description":"","main":"lib/index.js","typings":"lib/index","scripts":{"build":"tsc","test":"nyc mocha"},"nyc":{"include":["src/**/*.ts"],"extension":[".ts",".tsx"],"require":["ts-node/register"],"reporter":["text-summary","html"],"sourceMap":true,"instrument":true},"author":{"name":"Sean Drumm","email":"sean@seandrumm.co.uk"},"license":"MIT","dependencies":{"@types/debug":"0.0.30","@types/kafka-node":"^2.0.6","debug":"^3.1.0","kafka-node":"^2.3.2"},"devDependencies":{"@3g/tslint-rules":"^1.0.0","@types/chai":"^4.0.6","@types/chai-as-promised":"^7.1.0","@types/mocha":"^2.2.44","@types/nock":"^8.2.1","@types/node":"^8.0.49","nock":"^9.1.4","nyc":"^11.3.0","source-map-support":"^0.5.0","ts-node":"^3.3.0","tslint":"^5.8.0","tslint-eslint-rules":"^4.1.1","typescript":"^2.6.1","chai":"^4.1.2","chai-as-promised":"^7.1.1","mocha":"^4.0.1"},"gitHead":"8a58ecdc217352a7b353ed82caa2766c9645a9c1","_id":"@3g/kafka-wrapper@1.0.0","_npmVersion":"5.6.0","_nodeVersion":"8.9.4","_npmUser":{"name":"sjdweb","email":"sean.drumm@gmail.com"},"dist":{"integrity":"sha512-vAj7uVGG3W41MMTLZuBLWoQF0+ZtFuBPo93lYvV3uq3JSCleZx+Lmnio4+of9qF6q49A+UEOmiIxRxtU4HpBEQ==","shasum":"6fb346b9ad53575e469fc63d105e39586fc73aff","tarball":"https://registry.npmjs.org/@3g/kafka-wrapper/-/kafka-wrapper-1.0.0.tgz","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIEKUP8kjQXTKdE7Ge+0Q2lBzTgiYgTEm/ANF4/+gJ8NuAiAFqvsHxcLuXkec9vw6FlrUS5r9D26BVq59KRN1SYDEhQ=="}]},"maintainers":[{"name":"sjdweb","email":"sean.drumm@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-wrapper-1.0.0.tgz_1517486850452_0.5749099464155734"},"directories":{}},"1.0.1":{"name":"@3g/kafka-wrapper","version":"1.0.1","description":"","main":"lib/index.js","typings":"lib/index","scripts":{"build":"tsc","test":"nyc mocha"},"nyc":{"include":["src/**/*.ts"],"extension":[".ts",".tsx"],"require":["ts-node/register"],"reporter":["text-summary","html"],"sourceMap":true,"instrument":true},"author":{"name":"Sean Drumm","email":"sean@seandrumm.co.uk"},"license":"MIT","dependencies":{"@types/debug":"0.0.30","@types/kafka-node":"^2.0.6","debug":"^3.1.0","kafka-node":"^2.3.2"},"devDependencies":{"@3g/tslint-rules":"^1.0.0","@types/chai":"^4.0.6","@types/chai-as-promised":"^7.1.0","@types/mocha":"^2.2.44","@types/nock":"^8.2.1","@types/node":"^8.0.49","nock":"^9.1.4","nyc":"^11.3.0","source-map-support":"^0.5.0","ts-node":"^3.3.0","tslint":"^5.8.0","tslint-eslint-rules":"^4.1.1","typescript":"^2.6.1","chai":"^4.1.2","chai-as-promised":"^7.1.1","mocha":"^4.0.1"},"gitHead":"8951f392c231f75cfb7f8e5771c2d92d2a3d4b4c","_id":"@3g/kafka-wrapper@1.0.1","_npmVersion":"5.6.0","_nodeVersion":"8.9.4","_npmUser":{"name":"sjdweb","email":"sean.drumm@gmail.com"},"dist":{"integrity":"sha512-BkeSz/HTPsmNvFEtosXp/0wgQwr/SPjNWtyPW3mV0QuCYbd9OX9EXXnEfQ+zR+6zOjDaxdEl9eDRL2rkPfa8Gg==","shasum":"a9d6b533427058cda93db8eed048ef2537a20b37","tarball":"https://registry.npmjs.org/@3g/kafka-wrapper/-/kafka-wrapper-1.0.1.tgz","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIGc9hS9Cd+hTv/PEbm7SDLQ/OPNkB/hXpUtkK5M0TFohAiEAzgZNelYiiVkR7kekMMTlcLdOMcOI8mrCqr1gq01vix4="}]},"maintainers":[{"name":"02harlxj","email":"jackharley7@gmail.com"},{"name":"sjdweb","email":"sean.drumm@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-wrapper-1.0.1.tgz_1517571130678_0.007808144902810454"},"directories":{}},"2.0.0":{"name":"@3g/kafka-wrapper","version":"2.0.0","description":"A lightweight Kafka wrapper that creates listeners and publisher.","main":"lib/index.js","typings":"lib/index","scripts":{"build":"tsc","test":"nyc mocha"},"nyc":{"include":["src/**/*.ts"],"extension":[".ts",".tsx"],"require":["ts-node/register"],"reporter":["text-summary","html"],"sourceMap":true,"instrument":true},"author":{"name":"Sean Drumm","email":"sean@seandrumm.co.uk"},"license":"MIT","dependencies":{"@types/debug":"0.0.30","debug":"^3.1.0","node-rdkafka":"^2.4.1"},"devDependencies":{"@3g/tslint-rules":"^1.0.2","@types/chai":"^4.0.6","@types/chai-as-promised":"^7.1.0","@types/mocha":"^2.2.44","@types/nock":"^8.2.1","@types/node":"^8.0.49","chai":"^4.1.2","chai-as-promised":"^7.1.1","mocha":"^4.0.1","nock":"^9.1.4","nyc":"^11.3.0","source-map-support":"^0.5.0","ts-node":"^3.3.0","tslint":"^5.8.0","tslint-eslint-rules":"^4.1.1","typescript":"^2.6.1"},"gitHead":"d1bd4b67c03817381198acd214794322fb6ab183","_id":"@3g/kafka-wrapper@2.0.0","_npmVersion":"5.6.0","_nodeVersion":"8.9.4","_npmUser":{"name":"sjdweb","email":"sean.drumm@gmail.com"},"dist":{"integrity":"sha512-KfU0w6APjbJbpPqJYVQEIbi+QxSZPoh10H5/XicXbcDgzZoUKPV5InznS3v0sLFf35/A5f3mxj4E+MNyfxct7Q==","shasum":"56cd23784aaf2454dfc5edeb200a2dfe1750661d","tarball":"https://registry.npmjs.org/@3g/kafka-wrapper/-/kafka-wrapper-2.0.0.tgz","fileCount":11,"unpackedSize":15332,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJbjQGkCRA9TVsSAnZWagAA0TAQAJTH+HFqmsAsetWjbd36\nUq8mVTPS46sPipoDUdE83VoYKMn3zfcf/GfdUCODfswgYmmYAoLtBDQu4KDZ\nMSjlHNSzLmxzdfd1IyzW0uqCz2AQGIG7XP8NSN4yAG42sJ1DtsZzd/iccBNK\nCiT+nWVuz9CBzuxYOoh435Nm9zLBhHPzxyvBROBsosk2EPnA+fZYL4xPOihT\n+NvNb7Rk+JpD+sW568IEmtYfZSRseEhQJS8B0zUZ8EVpVr6jgfix6u3Lf0BJ\nokAk7xG52CThORi2oagdYdHxPcnnnCLMW/5APOX2E23ihh9hdl2KagKg8rA5\nR8VznBxC2WxlRrTGB5YcL35Izj733Q+6yCFxGc9WZfG1+R7oxls8oKdy4MMg\nK+HopZa3DgaycTDjAaJRy0M/5AcsTazX2RpseLoJzW1gcDIxpn6s7KDX7Ker\neCMt9pZGEhzWvi6S1pCTczeZ4gp1VqogOiSAbnenOp6dIoOvmiQLYrpXaaCt\nVvdQMdyoG7wS7pB303/hKH16EiP7ewQY7cNtuDiX+XZoyfFTOJY7JiCTayUF\niG35v//AX4aMbwsZARxlzRh/mb+ST1Zt0Xb4p/eeYU4PDH01kUQZVQXOS8bm\n85rE9zOJJw/IFwKPjywpP5rSiNXyEYM64GVQ8n81DUObyyN053nsR0CYpHoB\nM9Cn\r\n=V/dY\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQD+7BHdHv3Yjc+i+WEgXKGDaw/jzO2v6HJKBF7gdj4/VwIgCduRrBVFR96ANLVpkbKkypvFoCTulFj0j+d08IVslRw="}]},"maintainers":[{"name":"02harlxj","email":"jackharley7@gmail.com"},{"name":"sjdweb","email":"sean.drumm@gmail.com"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-wrapper_2.0.0_1535967651756_0.3786725213518056"},"_hasShrinkwrap":false},"2.0.1":{"name":"@3g/kafka-wrapper","version":"2.0.1","description":"A lightweight Kafka wrapper that creates listeners and publisher.","main":"lib/index.js","typings":"lib/index","scripts":{"build":"tsc","test":"nyc mocha"},"nyc":{"include":["src/**/*.ts"],"extension":[".ts",".tsx"],"require":["ts-node/register"],"reporter":["text-summary","html"],"sourceMap":true,"instrument":true},"author":{"name":"Sean Drumm","email":"sean@seandrumm.co.uk"},"license":"MIT","dependencies":{"@types/debug":"0.0.30","debug":"^3.1.0","node-rdkafka":"^2.4.1"},"devDependencies":{"@3g/tslint-rules":"^1.0.2","@types/chai":"^4.0.6","@types/chai-as-promised":"^7.1.0","@types/mocha":"^2.2.44","@types/nock":"^8.2.1","@types/node":"^8.0.49","chai":"^4.1.2","chai-as-promised":"^7.1.1","mocha":"^4.0.1","nock":"^9.1.4","nyc":"^11.3.0","source-map-support":"^0.5.0","ts-node":"^3.3.0","tslint":"^5.8.0","tslint-eslint-rules":"^4.1.1","typescript":"^2.6.1"},"gitHead":"15f4db8df6af77d31a482679e019dff234143df1","_id":"@3g/kafka-wrapper@2.0.1","_npmVersion":"5.6.0","_nodeVersion":"8.9.4","_npmUser":{"name":"sjdweb","email":"sean.drumm@gmail.com"},"dist":{"integrity":"sha512-lKM4IblQiIiTsqqzgT3jehUOGa0Uouo/HpznEMDhg942BpNEG/1h5MynNOUFs15iKy3UrYiE79yVaXUS6wOYNA==","shasum":"8b1616fd2dc31a773e6938b558da282ee8678388","tarball":"https://registry.npmjs.org/@3g/kafka-wrapper/-/kafka-wrapper-2.0.1.tgz","fileCount":11,"unpackedSize":15944,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJbsk9/CRA9TVsSAnZWagAA5IMP+gNJLyXVe8pvRpHHTBPe\nvEOEwRYO9RpQMYyf7ZiwZ2qTWMKGZSrFSgQCEBsPw9aQg7fAmWIEzcdDoUxN\nELYV+2X407Xra0dkQyP2gdUSLQ/78ybWAKaj8is95cbx0NUo+80e0g4XCf2d\nS2SzcX+iksukWxKDom2VQsRSgZFgQIUN4cdoahhAelzmihVN/fZWnlHSaLfF\nNkzN1YkLYeIkGAuvERdZxeQ4lBsxApv2JCubNr0N7jeBOg9sEEB/nVPZxwDA\nH7ld8rItRlt8Bj+YVLRxWGt71rvRFTFwtx0o4NQ1fAs4DKYXIiiNQ61KnliV\nPHqi36SBELw2I+oVxVVY0sGA9LKOcJbQJLmAFsWHTCrA2aOS36WlEpyneagC\nSb8IQxq5XaGv39Ysb/hY5gCqlr/j/F4/Xz7Vjn/EHPgwATG/PLbGeIirZNEw\nhxz8Pl/DokXvTYgRqkj/tQSFvZmgVAxUj8pCkrlLgkw5U2rNqf9RCd4/3nlu\nBUt0S9o9M6sUhKwEU6iTx32EI2slnbNMyG3AzQm+SzUcwNoNBDhR7r54AtqQ\n0FbGmqW+SHi5feFQOqtrvfb56UYitQ7ba4Ltdoa664DxobhEl7lTEYvy+jvE\nhJnYOuLEWFndldu66X4uKqZMCnmFK/+Xsqo7mbgopiF5ZWNwYy8yYrKegpQD\nZ4AM\r\n=Byfw\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCUC9eDmbWUaTuFkxeRy2JSQhMWkS3vGRAmAoiitgn8LgIhAPmdl/cEIBxa3ILqaPLNMMFNQ3AMgd+/yulKX3+gQ6c5"}]},"maintainers":[{"email":"jackharley7@gmail.com","name":"02harlxj"},{"email":"anicoll01@gmail.com","name":"nicoll1"},{"email":"sean.drumm@gmail.com","name":"sjdweb"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-wrapper_2.0.1_1538412414365_0.37070457276535995"},"_hasShrinkwrap":false},"2.0.2":{"name":"@3g/kafka-wrapper","version":"2.0.2","description":"A lightweight Kafka wrapper that creates listeners and publisher.","main":"lib/index.js","typings":"lib/index","scripts":{"build":"tsc","test":"nyc mocha"},"nyc":{"include":["src/**/*.ts"],"extension":[".ts",".tsx"],"require":["ts-node/register"],"reporter":["text-summary","html"],"sourceMap":true,"instrument":true},"author":{"name":"Sean Drumm","email":"sean@seandrumm.co.uk"},"license":"MIT","dependencies":{"@types/debug":"0.0.30","debug":"^3.1.0","node-rdkafka":"^2.4.1"},"devDependencies":{"@3g/tslint-rules":"^1.0.2","@types/chai":"^4.0.6","@types/chai-as-promised":"^7.1.0","@types/mocha":"^2.2.44","@types/nock":"^8.2.1","@types/node":"^8.0.49","chai":"^4.1.2","chai-as-promised":"^7.1.1","mocha":"^4.0.1","nock":"^9.1.4","nyc":"^11.3.0","source-map-support":"^0.5.0","ts-node":"^3.3.0","tslint":"^5.8.0","tslint-eslint-rules":"^4.1.1","typescript":"^2.6.1"},"gitHead":"49996ffa6289393762d03f44e8565c630324ea8f","_id":"@3g/kafka-wrapper@2.0.2","_npmVersion":"5.6.0","_nodeVersion":"8.9.4","_npmUser":{"name":"sjdweb","email":"sean.drumm@gmail.com"},"dist":{"integrity":"sha512-81rvLnhQsRaMTzvTK1FK92o47nk2gqfendQrJlzHcuma1UoYVWKOGeoZ+L7QB03In9JjG6rDk8VhTP101s8Btg==","shasum":"ffead50226f17e99f20eaa1ed4de7b772d3ea8cb","tarball":"https://registry.npmjs.org/@3g/kafka-wrapper/-/kafka-wrapper-2.0.2.tgz","fileCount":11,"unpackedSize":15826,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJb4G5nCRA9TVsSAnZWagAAEsQQAIXSfrs4eJTE2+e1GspW\nTLeYfksCGLeO8l8XQ34bxFYLpaUws8ur8EsCkYxKABFu5ate67WLruA0v6oE\nPKak4pTqRGG+AWI18Ev864/GEVO/19HJfN/bRDqRmpANYLxRJ6U50P2UV0/p\nIZo1iSZIbersP+SB8U1HMtXisKgbIz95mitDcwJCDpnyq0U1bvO+sJxm/D2l\nQHuAZuKyw/bNqJVVAky/CU2Jwqgco9drIwEa8xT3o9YVh+S4mp0/L+f7t7JH\nEyloP+0KF2L+hslMUl9KjAH8ChL9l6XeA/61ALBQ06Q7jdxs+aiaBCOzqe9r\njrCdb3xqNPYzBkUW0hioEKM25ErDh9XrEcWmaCZsDTvxOgZaCwdLoVFOFpJA\n7+mp1gAov2nSEQ+0LDObYPvMussBMWVBriCI/S+PN8SGl0/l9mZR+uBirEcM\nag6bekJSgiSKutmZL2gMC7hN35l1DRGAUCwY1SvMmkKNmkZVOvBMIYMX+PO/\nkKGDtTzrv5nuBn7TpjYW3IBdXUD36EBB97O1JrXiCwBXbHNEYloeIvGUqjXS\nrmBseqWysKc6ApFGuEt60T3zcQe0prM9pJL6gUaPopMtCyhWBkWmxiX1sOZZ\nuLS97v5QMf5j5+WUB5u/Olal2CyanN0vI/tdSI2CWT+XwmFdtvgARy7NtMSa\nNo9+\r\n=PZ1y\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQC+KwEgv36auy/EuctkuMZsh54cw0xO4NeolYemFX0dswIhAL9HNhP0tlwYjH6P472BsZAvhV+ALKTyVEsR0m7rVFFc"}]},"maintainers":[{"email":"jackharley7@gmail.com","name":"02harlxj"},{"email":"anicoll01@gmail.com","name":"nicoll1"},{"email":"sean.drumm@gmail.com","name":"sjdweb"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-wrapper_2.0.2_1541434983066_0.9658971653552537"},"_hasShrinkwrap":false},"2.0.3":{"name":"@3g/kafka-wrapper","version":"2.0.3","description":"A lightweight Kafka wrapper that creates listeners and publisher.","main":"lib/index.js","typings":"lib/index","scripts":{"build":"tsc","test":"nyc mocha"},"nyc":{"include":["src/**/*.ts"],"extension":[".ts",".tsx"],"require":["ts-node/register"],"reporter":["text-summary","html"],"sourceMap":true,"instrument":true},"author":{"name":"Sean Drumm","email":"sean@seandrumm.co.uk"},"license":"MIT","dependencies":{"@types/debug":"0.0.30","debug":"^3.1.0","node-rdkafka":"^2.4.1"},"devDependencies":{"@3g/tslint-rules":"^1.0.2","@types/chai":"^4.0.6","@types/chai-as-promised":"^7.1.0","@types/mocha":"^2.2.44","@types/nock":"^8.2.1","@types/node":"^8.0.49","chai":"^4.1.2","chai-as-promised":"^7.1.1","mocha":"^4.0.1","nock":"^9.1.4","nyc":"^11.3.0","source-map-support":"^0.5.0","ts-node":"^3.3.0","tslint":"^5.8.0","tslint-eslint-rules":"^4.1.1","typescript":"^2.6.1"},"gitHead":"b37e6bd2e4ab03077bb7ded4b19a730d5daf2967","_id":"@3g/kafka-wrapper@2.0.3","_npmVersion":"6.4.1","_nodeVersion":"8.9.4","_npmUser":{"name":"sjdweb","email":"sean.drumm@gmail.com"},"dist":{"integrity":"sha512-8zCSDlj4ciStBtTj18LMKaT3YzXtUanhP84tq2YEAXAmK2NcjgaPqgEZ0OXU15p2qgj9JxflSQIE6r1sUuqz8A==","shasum":"8373d3569a352dd5b1ac4a35345a8b0672246dab","tarball":"https://registry.npmjs.org/@3g/kafka-wrapper/-/kafka-wrapper-2.0.3.tgz","fileCount":11,"unpackedSize":15973,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJc0CQECRA9TVsSAnZWagAAp2MQAIaDGBf2BYruVMkGC1hN\nvdutEBANHGsAto1HLjXIfjmHPBnO0GJZtFBXLlxAGdMQ6IYX8HpTBPQ/j4yy\n6Rhi7E8h2tfMV6aGt+3Fs1YBVCOR1lILazeFr/HfKuCVXiKvTXb0lKGTcf3D\nTIVHqDmol/atmHQuKobnsWJ74/IAL9v1KitwnXNFsu3Sbzb1U48OSgfT7dQI\nw5lYlbskngPbtrZOV/FpYzrsvJU2Out/pQ8zuVHGOLHtipSCQMn+JXrQTg09\netEd0+QtbsTa094lrSV06IL+zMdRzQzq5oB/XTJNWuJ+0WYejSJ69DZrXTDS\naTrWo7T6sTaCxG8dtLK9gcleZyqDh3YgOgoIOmCgxB2fZuGUcwUfn6UC5zeL\nN/tTIP9y2LdwDxcfJ4Wx+qTLPv8YnnFkJSKGBoKAF9JxRu/6UhS5fjJY7QVR\ngs6xWwRYV7GXZo1rfZwFJwkeHHQCgSPR+rS4fyWbLYHb7tkgPIQZ+H1oGoj+\neEv1nKHkFQV+dK8I2kls/zAZjIl64lO6HbWNNrGraU1MoeNR0VX0xPt9cEF4\nJADiazTCaclJUcE8fbFWYapXf7INbFmihCYFuruHOItAPqEn0/cUV+CKxuqJ\n1IvkkfY1DunQR5X3JmLBtcVtkXTW7OM6s8WdVIpDHHc9zEplhjrWSuq9Qsde\nR78p\r\n=G01+\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIA+sZp4nqMnygEcqVz5cI3WoACugC2VVXQTehpm9bcxoAiEA6pIKRThWDDHfQxo+Fek7G6bRsVZ21OjvOsNUGyQ5MVU="}]},"maintainers":[{"email":"jackharley7@gmail.com","name":"02harlxj"},{"email":"anicoll01@gmail.com","name":"nicoll1"},{"email":"sean.drumm@gmail.com","name":"sjdweb"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-wrapper_2.0.3_1557144579458_0.6404452219863677"},"_hasShrinkwrap":false},"2.0.4":{"name":"@3g/kafka-wrapper","version":"2.0.4","description":"A lightweight Kafka wrapper that creates listeners and publisher.","main":"lib/index.js","typings":"lib/index","scripts":{"build":"tsc","test":"mocha -r ts-node/register --timeout 999999 --colors ./src/*.spec.ts --exit"},"nyc":{"include":["src/**/*.ts"],"extension":[".ts",".tsx"],"require":["ts-node/register"],"reporter":["text-summary","html"],"sourceMap":true,"instrument":true},"author":{"name":"Sean Drumm","email":"sean@seandrumm.co.uk"},"license":"MIT","dependencies":{"@types/debug":"4.1.4","debug":"^4.1.1","node-rdkafka":"^2.7.0"},"devDependencies":{"@3g/tslint-rules":"^1.0.2","@types/chai":"^4.1.7","@types/chai-as-promised":"^7.1.0","@types/mocha":"^5.2.7","@types/nock":"^10.0.3","@types/node":"^10.12.18","chai":"^4.2.0","chai-as-promised":"^7.1.1","mocha":"^5.2.0","nock":"^10.0.6","nyc":"^13.1.0","source-map-support":"^0.5.12","ts-node":"^8.3.0","tslint":"^5.18.0","tslint-eslint-rules":"^5.4.0","typescript":"^3.5.2"},"gitHead":"3334ed77688b4c06e1bd3b919b6ff027bc98e106","_id":"@3g/kafka-wrapper@2.0.4","_npmVersion":"6.5.0","_nodeVersion":"10.13.0","_npmUser":{"name":"nicoll1","email":"anicoll01@gmail.com"},"dist":{"integrity":"sha512-uho5qIzxXH1bGvycq/1IiEYpDGXcuy+J+nxzlB9qcYrKH+XGVIcTxrSS6RVXZbBqLlKtRSZ/peX16zKha3euuw==","shasum":"c91806492c448896feb075927a2f7654f13d7e3f","tarball":"https://registry.npmjs.org/@3g/kafka-wrapper/-/kafka-wrapper-2.0.4.tgz","fileCount":12,"unpackedSize":17531,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJdELUKCRA9TVsSAnZWagAAaysP/imisce9hIwexkeno5xG\n+RxeSTFuWUkGA5rZps/+xQFRCHM4YV9IUIJQxa/hIkjS+0I6cjD8mlQVfX17\nCl1aNIh+vpGPvo52grMQOuZN0uOCuEyjOLhNQlRYJkQkNTs/vttxr1ul+ZzQ\nyG2US1xfmi7cycb9bP+fjsNKTQTdutipZVX1eLXs9pTFYXQGS4SEaQlA8fJD\nFTiY+8GWwskFiGbOZ/m4MElFiPk0qNXa0TR2Bnn2LF2K9QTchuS1k4/Xyn71\nay8f5MCBQIfNujCJjIaeT7DPAWwL08GgDpxg/EBzVnOeuFfZdQlREEGOOJ2f\nPM/MgP8Gy8GJDnsjiI+WEgQtW6mvgJwuvB756HdAEo3G2cqzq4vZ4FtbJzsT\n+jE9n2XAkVXhizjQV6g1ywgtxyvY624H3oPQnChM6Aa1Kor32xz+TZSKsP2c\nm4ImfooKf7lXHHto01IKZJoMd/VNHLu42QwaKnlyhZdt8evMQiHCHRa4MaUM\n2ZirxPk98NeG3jhvxTWaJmibUJUzzXdBix0ZUPMnmiBawq7SA5mH0HXUsMBH\n5CDunBLyoj9oNOW9sx+q0CXjxmNhZ/CoTxC84RzU/Ke2IqCeasrrP5n5FWqs\nJ8VQqVXVK13sd6ypfddc3zpqNX0ujDi2+fKGI7Cup/CEbibpWKc4ebA8ysYb\nTJV0\r\n=Vx8J\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDpmjKFWfv3fTPlkabG/annLh7ERIcW1tVQ78o4I/IfeAIgKW4Ddt2C2g1668t1I+XYgdUZybLkSPIbczWFqhNmyu4="}]},"maintainers":[{"email":"jackharley7@gmail.com","name":"02harlxj"},{"email":"anicoll01@gmail.com","name":"nicoll1"},{"email":"sean.drumm@gmail.com","name":"sjdweb"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-wrapper_2.0.4_1561376009487_0.5921021697534303"},"_hasShrinkwrap":false}},"readme":"# Kafka Wrapper\n\nA lightweight Kafka wrapper that creates listeners and publisher.\n\nCurrently uses `node-rdkafka` behind the scenes.\n\n# Usage\n\n### Listener\n```ts\nconst listener = kafkaListener({\n  host: '127.0.0.1:29092',\n  groupId: 'testing.123',\n  topics: ['test-wrapper'],\n}, (message: IMessage) => {\n  console.log('here be msgs', message);\n  console.log('message value', message.value.toString());\n}, (err: Error) => {\n  console.error('Err', err);\n});\n```\n\n### Publisher\n```ts\nconst publisher = kafkaPublisher({\n  host: '127.0.0.1:29092',\n  clientId: 'testing-wrapper-publisher',\n}, (err: Err) => {\n  console.error('Err', err);\n});\n\npublisher.send({\n  topic: 'test-wrapper',\n  message: {\n    stuff: 123,\n  },\n}).then(() => {\n  console.log('Message sent successfully', i);\n}).catch(err => {\n  console.error('Err sending message', err);\n});\n\n```\n\n# Notes\n\n### Consumer Groups\n- [rebalancing](https://stackoverflow.com/questions/28574054/kafka-consumer-rebalancing-algorithm)\n- [consumer assignments](https://www.signal.co/dev-log/kafka-consumer-assignments/)","maintainers":[{"email":"jackharley7@gmail.com","name":"02harlxj"},{"email":"anicoll01@gmail.com","name":"nicoll1"},{"email":"sean.drumm@gmail.com","name":"sjdweb"}],"time":{"modified":"2022-04-04T10:44:47.154Z","created":"2018-02-01T12:07:31.392Z","1.0.0":"2018-02-01T12:07:31.392Z","1.0.1":"2018-02-02T11:32:11.901Z","2.0.0":"2018-09-03T09:40:51.898Z","2.0.1":"2018-10-01T16:46:54.489Z","2.0.2":"2018-11-05T16:23:03.264Z","2.0.3":"2019-05-06T12:09:39.573Z","2.0.4":"2019-06-24T11:33:29.669Z"},"author":{"name":"Sean Drumm","email":"sean@seandrumm.co.uk"},"license":"MIT","readmeFilename":"README.md","description":"A lightweight Kafka wrapper that creates listeners and publisher."}