{"_id":"kafka-streams","_rev":"48-2f0795f72442a5136ecec417296018b2","name":"kafka-streams","description":"kafka-streams for Node.js","dist-tags":{"latest":"5.0.0"},"versions":{"0.9.0":{"name":"kafka-streams","version":"0.9.0","description":"kafka-streams for nodejs","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","test":"istanbul cover _mocha -- --recursive -R spec test && istanbul check-coverage --statements 60"},"repository":{"type":"git","url":"git+https://github.com/krystianity/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/krystianity/kafka-streams/issues"},"homepage":"https://github.com/krystianity/kafka-streams#readme","dependencies":{"sinek":"~3.2.0"},"devDependencies":{"expect.js":"~0.3.1","mocha":"~3.2.0","istanbul":"~0.4.2"},"gitHead":"42799da0bc1fde568d93b6e65708eb87ec4c1c67","_id":"kafka-streams@0.9.0","_shasum":"3f2d22a4c5f22a126cade0a78608435c2a0052b4","_from":".","_npmVersion":"4.0.5","_nodeVersion":"7.4.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"shasum":"3f2d22a4c5f22a126cade0a78608435c2a0052b4","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-0.9.0.tgz","integrity":"sha512-vCSfP/jzMW0cf/2E1mr5X7NXUfEQvyUewL2P7VaxAQejQcZCWBOxuC46JMHtIvDZ8keZnnW7YHnn75XHg5NYIw==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDRljol3n2IV0oJ+0PNNCxs6SkFEA1xJDx40F8sHLqzOQIgG6A0PcW5C1AsQQCTETGrMfoC9MqN2wDolQ5nWYo7abs="}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"_npmOperationalInternal":{"host":"packages-18-east.internal.npmjs.com","tmp":"tmp/kafka-streams-0.9.0.tgz_1491520374066_0.39983960543759167"},"directories":{}},"0.10.0":{"name":"kafka-streams","version":"0.10.0","description":"kafka-streams for nodejs","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"node ./examples/observableTest.js","test":"istanbul cover _mocha -- --recursive -R spec test && istanbul check-coverage --statements 75"},"repository":{"type":"git","url":"git+https://github.com/krystianity/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/krystianity/kafka-streams/issues"},"homepage":"https://github.com/krystianity/kafka-streams#readme","dependencies":{"bluebird":"~3.5.0","most":" ~1.2.2","sinek":"~3.2.0"},"devDependencies":{"istanbul":"~0.4.2","mocha":"~3.2.0","proxyquire":"~1.7.11"},"gitHead":"4dcb636e1bd71d3cbd3e4d4fe499c8ce5ed149c3","_id":"kafka-streams@0.10.0","_shasum":"4b0f2cef6191fe09506c2b9ae47e4e5aa72ccc21","_from":".","_npmVersion":"4.0.5","_nodeVersion":"7.4.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"shasum":"4b0f2cef6191fe09506c2b9ae47e4e5aa72ccc21","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-0.10.0.tgz","integrity":"sha512-ic2X4uq7JwbsU2gBazFy6/A1Whm6gxC1ezgj1qRMsSdOSd0ca1dXcg+yxnEJ9+RZg0w5qiGLk2Q4gDBUx01ljQ==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIBCToKmN2pY2KxKzGb4XxxWPavijDaB1SicOxRczK+ErAiA2Ddx1cz5dCYRAq35v6EmG55W4PcgcGj6N7ZY8lLc+AA=="}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"_npmOperationalInternal":{"host":"packages-18-east.internal.npmjs.com","tmp":"tmp/kafka-streams-0.10.0.tgz_1491606093524_0.5329114797059447"},"directories":{}},"0.11.0":{"name":"kafka-streams","version":"0.11.0","description":"kafka-streams for nodejs","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"node ./examples/observableTest.js","test":"istanbul cover _mocha -- --recursive -R spec test && istanbul check-coverage --statements 75"},"repository":{"type":"git","url":"git+https://github.com/krystianity/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/krystianity/kafka-streams/issues"},"homepage":"https://github.com/krystianity/kafka-streams#readme","dependencies":{"@most/create":"~2.0.1","bluebird":"~3.5.0","most":" ~1.2.2","sinek":"~3.2.0"},"devDependencies":{"istanbul":"~0.4.2","mocha":"~3.2.0","proxyquire":"~1.7.11"},"gitHead":"3644b36e8c28b9880b7788d3c61518e250ca096d","_id":"kafka-streams@0.11.0","_shasum":"db109794dc0360484eb7d7e0a649c1bf85cdb4ec","_from":".","_npmVersion":"4.0.5","_nodeVersion":"7.4.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"shasum":"db109794dc0360484eb7d7e0a649c1bf85cdb4ec","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-0.11.0.tgz","integrity":"sha512-Q8rDWgR9wFHYkkppnTuO4uNUkOub0VXXNshpK57iQ+DTh4msvqipBGfovI1DPBje5DN1ujY1Ymu4W484r6poTw==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIBkKm9QtsQmPpyxZJraS32ojxIj387Njb/UBvdg0NzL/AiEAxAbXvsTtLXmET6nMaiuy6NJKandKfgIm25/7wm3WLd8="}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"_npmOperationalInternal":{"host":"packages-12-west.internal.npmjs.com","tmp":"tmp/kafka-streams-0.11.0.tgz_1491692806005_0.9931785417720675"},"directories":{}},"0.12.0":{"name":"kafka-streams","version":"0.12.0","description":"kafka-streams for nodejs","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"mocha test/unit/Observable.test.js","test":"istanbul cover _mocha -- --recursive -R spec test && istanbul check-coverage --statements 75"},"repository":{"type":"git","url":"git+https://github.com/krystianity/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/krystianity/kafka-streams/issues"},"homepage":"https://github.com/krystianity/kafka-streams#readme","dependencies":{"@most/create":"~2.0.1","bluebird":"~3.5.0","most":" ~1.2.2","sinek":"~3.2.0"},"devDependencies":{"istanbul":"~0.4.2","mocha":"~3.2.0","proxyquire":"~1.7.11"},"gitHead":"a424c615f61249d055a58b5c49ca082cd10e29af","_id":"kafka-streams@0.12.0","_shasum":"c406b9ee38b8bcd86be6fb6e7072bb5db58b9faf","_from":".","_npmVersion":"4.0.5","_nodeVersion":"7.4.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"shasum":"c406b9ee38b8bcd86be6fb6e7072bb5db58b9faf","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-0.12.0.tgz","integrity":"sha512-j9GhQcf7YcHKOr0OqxWDJ71a4jWQbbFveNX5v6axjU38O4r/dZCri6cnKSC0KauRLsJFAoODV0n+umshG3ndBA==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQD/uEhUPQKBW+dzQTUQOMG2GUzEYCNvxdAK3vEbRC6YCwIgV1zKlThWzpFNp4+2ok8wuZR9RB2pGVJfkYmjpopslaY="}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"_npmOperationalInternal":{"host":"packages-18-east.internal.npmjs.com","tmp":"tmp/kafka-streams-0.12.0.tgz_1491744582900_0.6690532688517123"},"directories":{}},"0.13.0":{"name":"kafka-streams","version":"0.13.0","description":"kafka-streams for nodejs","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"mocha test/unit/Observable.test.js","test":"istanbul cover _mocha -- --recursive -R spec test && istanbul check-coverage --statements 75"},"repository":{"type":"git","url":"git+https://github.com/krystianity/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/krystianity/kafka-streams/issues"},"homepage":"https://github.com/krystianity/kafka-streams#readme","dependencies":{"@most/create":"~2.0.1","bluebird":"~3.5.0","most":" ~1.2.2","sinek":"~3.2.0"},"devDependencies":{"istanbul":"~0.4.2","mocha":"~3.2.0","proxyquire":"~1.7.11"},"gitHead":"ca3de7dd5abeb8a83e1863bc527e2e6962bca1ba","_id":"kafka-streams@0.13.0","_shasum":"3e898330644eb7162450c68c8c3d10117aa43176","_from":".","_npmVersion":"4.0.5","_nodeVersion":"7.4.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"shasum":"3e898330644eb7162450c68c8c3d10117aa43176","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-0.13.0.tgz","integrity":"sha512-fvo65H9nKEkoSnj2tbfXCfMQ8OvkFRSU1ua98O8NyMtiCld+58uaRajAnD4k6+xcf4rDSPymwAuoii9j7NRKCg==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQCNBIkJQnBQn5chhLFh4IEvH02HyO+86JEaVUvtn+XE9AIgf3Op1Vlgi6oafbai+ciwC0ptBuNfBNdpgv9KNTi3d7w="}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"_npmOperationalInternal":{"host":"packages-18-east.internal.npmjs.com","tmp":"tmp/kafka-streams-0.13.0.tgz_1492078754119_0.045040491269901395"},"directories":{}},"0.14.0":{"name":"kafka-streams","version":"0.14.0","description":"kafka-streams for nodejs","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"mocha test/unit/Observable.test.js","test":"istanbul cover _mocha -- --recursive -R spec test && istanbul check-coverage --statements 75"},"repository":{"type":"git","url":"git+https://github.com/krystianity/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/krystianity/kafka-streams/issues"},"homepage":"https://github.com/krystianity/kafka-streams#readme","dependencies":{"@most/create":"~2.0.1","bluebird":"~3.5.0","most":" ~1.2.2","sinek":"~3.2.0"},"devDependencies":{"istanbul":"~0.4.2","mocha":"~3.2.0","proxyquire":"~1.7.11","uuid":"~3.0.1","log4bro":"~2.0.1"},"gitHead":"20495056a5fcfadfc5903fcaf6e2ef7a32863fa2","_id":"kafka-streams@0.14.0","_shasum":"8dfd0c72e1cb145ed57860317229506322557e96","_from":".","_npmVersion":"4.0.5","_nodeVersion":"7.4.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"shasum":"8dfd0c72e1cb145ed57860317229506322557e96","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-0.14.0.tgz","integrity":"sha512-gX1DXV6rVKKl2PgeGITIfHqDZrvUfn12m41vsL3GQOSHrebMRuLrEBTDahcKtAEdo9bddOW/qDHJJM22VcRcFA==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQD2SGL5r7qH15Pll6CclgtEFLxrtusi7ovTa+xqNhxxVAIhAKMgueAtJ18y6Aphz2vayJWdRAPH9aPReCHguIq5Fghm"}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"_npmOperationalInternal":{"host":"packages-12-west.internal.npmjs.com","tmp":"tmp/kafka-streams-0.14.0.tgz_1492099016616_0.30031087761744857"},"directories":{}},"0.17.0":{"name":"kafka-streams","version":"0.17.0","description":"kafka-streams for nodejs","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"mocha test/unit/Observable.test.js","test":"istanbul cover _mocha -- --recursive -R spec test && istanbul check-coverage --statements 75"},"repository":{"type":"git","url":"git+https://github.com/krystianity/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/krystianity/kafka-streams/issues"},"homepage":"https://github.com/krystianity/kafka-streams#readme","dependencies":{"@most/create":"~2.0.1","bluebird":"~3.5.0","most":" ~1.2.2","sinek":"~3.3.0"},"devDependencies":{"istanbul":"~0.4.2","mocha":"~3.2.0","proxyquire":"~1.7.11","uuid":"~3.0.1","log4bro":"~2.0.1"},"gitHead":"008de8e363367d5c37eab7eee8db868351e54863","_id":"kafka-streams@0.17.0","_shasum":"1a3f138cd88c25f4ff23b3545d4f8d76a0081e0f","_from":".","_npmVersion":"4.0.5","_nodeVersion":"7.4.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"shasum":"1a3f138cd88c25f4ff23b3545d4f8d76a0081e0f","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-0.17.0.tgz","integrity":"sha512-DoNA0wJvmSEFXTpyx/l1/zyO5VTj/b5S0tE3qoeeIIvY+w9DNny81k0Gx1KqYCoZY7VuobeoaEW9arAXDQQqRQ==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDYyDzojQs67kay7PBTFtBHY45QVjq9NmgND5r6Wi7X4AIgC1bsKbX5H4aMrRC0edkU6CfnlVCLhruVYq9LRMKQYZs="}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"_npmOperationalInternal":{"host":"packages-18-east.internal.npmjs.com","tmp":"tmp/kafka-streams-0.17.0.tgz_1492118235374_0.9420923937577754"},"directories":{}},"0.19.0":{"name":"kafka-streams","version":"0.19.0","description":"kafka-streams for nodejs","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"mocha test/unit/Observable.test.js","test-unit":"istanbul cover _mocha -- --recursive -R spec test/unit && istanbul check-coverage --statements 60","test-int":"istanbul cover _mocha -- --recursive -R spec test/int && istanbul check-coverage --statements 70","test":"npm run test-unit && npm run test-int"},"repository":{"type":"git","url":"git+https://github.com/krystianity/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/krystianity/kafka-streams/issues"},"homepage":"https://github.com/krystianity/kafka-streams#readme","dependencies":{"@most/create":"~2.0.1","bluebird":"~3.5.0","most":" ~1.2.2","sinek":"~3.4.0"},"devDependencies":{"istanbul":"~0.4.2","mocha":"~3.2.0","proxyquire":"~1.7.11","uuid":"~3.0.1","log4bro":"~2.0.1"},"gitHead":"7229b7b613cf524c7c2676852a44e7916f99d397","_id":"kafka-streams@0.19.0","_shasum":"c20120dc6e7ad263bffeebd69984f22986684399","_from":".","_npmVersion":"4.0.5","_nodeVersion":"7.4.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"shasum":"c20120dc6e7ad263bffeebd69984f22986684399","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-0.19.0.tgz","integrity":"sha512-BzHQqBTGjlTluQNbW8BTESA/RPRa6xG3kfodE6wFWxSud0F3pc566TIkD3itWc8QilSNPRuOfg5s565H7tc8ZA==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCL7TiMZg7qc+8dEuZJZ1dRnhraG2eShWTyZ8t+EJ50igIhAKi6iz1t+5bhoIWplwEDjIIf+vw1rhTgFVsBeezgzOv3"}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"_npmOperationalInternal":{"host":"packages-12-west.internal.npmjs.com","tmp":"tmp/kafka-streams-0.19.0.tgz_1492364227460_0.8099612805526704"},"directories":{}},"0.20.0":{"name":"kafka-streams","version":"0.20.0","description":"kafka-streams for nodejs","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"mocha test/unit/Observable.test.js","test-unit":"istanbul cover _mocha -- --recursive -R spec test/unit && istanbul check-coverage --statements 60","test-int":"istanbul cover _mocha -- --recursive -R spec test/int && istanbul check-coverage --statements 70","test":"npm run test-unit && npm run test-int"},"repository":{"type":"git","url":"git+https://github.com/krystianity/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/krystianity/kafka-streams/issues"},"homepage":"https://github.com/krystianity/kafka-streams#readme","dependencies":{"@most/create":"~2.0.1","bluebird":"~3.5.0","most":" ~1.2.2","sinek":"~3.4.0"},"devDependencies":{"istanbul":"~0.4.2","mocha":"~3.2.0","proxyquire":"~1.7.11","uuid":"~3.0.1","log4bro":"~2.0.1"},"gitHead":"836e3e724731080872c1648edcb3c81f29036a50","_id":"kafka-streams@0.20.0","_shasum":"241e82912c757e3846971726ff32cf6a1722b2ea","_from":".","_npmVersion":"4.0.5","_nodeVersion":"7.4.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"shasum":"241e82912c757e3846971726ff32cf6a1722b2ea","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-0.20.0.tgz","integrity":"sha512-EKI8JHH54M6X8+E53i1QraPwtqm1QWKE+4lFSNXWq45ImHrk++C/iNnzKA764V7XoyJFaJMKd3azqLHggO3+Kg==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIG+vPrCLSyqENLaHOepAnHLgVLWiaJaMNBaGU5+bnN0AAiBlxAu4IboqlUdSPHSnl2mIVX6dg0+mX+HamgalJl6Mag=="}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"_npmOperationalInternal":{"host":"packages-12-west.internal.npmjs.com","tmp":"tmp/kafka-streams-0.20.0.tgz_1492370876216_0.7668210850097239"},"directories":{}},"0.21.0":{"name":"kafka-streams","version":"0.21.0","description":"kafka-streams for nodejs","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"mocha test/unit/Observable.test.js","test-unit":"istanbul cover _mocha -- --recursive -R spec test/unit","test-int":"istanbul cover _mocha -- --recursive -R spec test/int && istanbul check-coverage --statements 70","test":"npm run test-unit && npm run test-int"},"repository":{"type":"git","url":"git+https://github.com/krystianity/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/krystianity/kafka-streams/issues"},"homepage":"https://github.com/krystianity/kafka-streams#readme","dependencies":{"bluebird":"~3.5.0","most":" ~1.2.2","most-subject":"^5.3.0","sinek":"~3.4.0"},"devDependencies":{"istanbul":"~0.4.2","log4bro":"~2.0.1","mocha":"~3.2.0","proxyquire":"~1.7.11","uuid":"~3.0.1"},"gitHead":"b4b878de7bc9a8f49bec82c7473ebc9d6d7d8073","_id":"kafka-streams@0.21.0","_shasum":"131042a2e941b0ae52a6e04ebad551c155e70d0a","_from":".","_npmVersion":"4.0.5","_nodeVersion":"7.4.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"shasum":"131042a2e941b0ae52a6e04ebad551c155e70d0a","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-0.21.0.tgz","integrity":"sha512-gd1iRBaw36H9XwysHUx4RQhF22jPlCx2DZG14lL1j1QMJQYNOvkj7wlkFD4Dh66vRzAP054qJanyWfe5ELbRcA==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIBhNOCgMtQtmoQh5/bcxTnPrTvZxJJRZnY4v+AEh3B5PAiEAmSIT0GJ+vB/QW5IX1xJIWW5gQ7QwrIh+ZyrG3d17xNg="}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"_npmOperationalInternal":{"host":"packages-18-east.internal.npmjs.com","tmp":"tmp/kafka-streams-0.21.0.tgz_1492547592405_0.03871031873859465"},"directories":{}},"0.22.0":{"name":"kafka-streams","version":"0.22.0","description":"kafka-streams for nodejs","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"mocha test/unit/Observable.test.js","test-unit":"istanbul cover _mocha -- --recursive -R spec test/unit","test-int":"istanbul cover _mocha -- --recursive --timeout 12500 -R spec test/int && istanbul check-coverage --statements 60","test":"npm run test-unit && npm run test-int"},"repository":{"type":"git","url":"git+https://github.com/krystianity/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/krystianity/kafka-streams/issues"},"homepage":"https://github.com/krystianity/kafka-streams#readme","dependencies":{"bluebird":"~3.5.0","most":" ~1.2.2","most-subject":"^5.3.0","sinek":"~3.4.0"},"devDependencies":{"istanbul":"~0.4.2","log4bro":"~2.0.1","mocha":"~3.2.0","proxyquire":"~1.7.11","uuid":"~3.0.1"},"gitHead":"6ceb59360ca6d0c7c112ead824f4e495c2dd56eb","_id":"kafka-streams@0.22.0","_shasum":"88aa27a3072dc34de56ff12b8cb551a81ebcf54c","_from":".","_npmVersion":"4.0.5","_nodeVersion":"7.4.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"shasum":"88aa27a3072dc34de56ff12b8cb551a81ebcf54c","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-0.22.0.tgz","integrity":"sha512-rudZz211Lhtdo9J2ecRQbvQDjVUHf34xudZnaiMIrUdqO1TnxymImWYklJWopKuJQfJpoQTKVqabYrHCmSHbBA==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCICD75qoFbQLFZ+IYsOsURTsPwg6jCW2MRzlkNxZef/fOAiEA2jmI6MDmmFSIooQST/W5kzdyezDE/gTxfkq8n9DhI1k="}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"_npmOperationalInternal":{"host":"packages-18-east.internal.npmjs.com","tmp":"tmp/kafka-streams-0.22.0.tgz_1492727931341_0.7930237140972167"},"directories":{}},"0.23.0":{"name":"kafka-streams","version":"0.23.0","description":"kafka-streams for nodejs","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"mocha test/unit/Observable.test.js","test-unit":"istanbul cover _mocha -- --recursive -R spec test/unit","test-int":"istanbul cover _mocha -- --recursive --timeout 12500 -R spec test/int && istanbul check-coverage --statements 60","test":"npm run test-unit && npm run test-int"},"repository":{"type":"git","url":"git+https://github.com/krystianity/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/krystianity/kafka-streams/issues"},"homepage":"https://github.com/krystianity/kafka-streams#readme","dependencies":{"bluebird":"~3.5.0","most":" ~1.2.2","most-subject":"^5.3.0","sinek":"~3.7.0"},"devDependencies":{"istanbul":"~0.4.2","log4bro":"~2.0.1","mocha":"~3.2.0","proxyquire":"~1.7.11","uuid":"~3.0.1","async":"~2.3.0"},"gitHead":"8206fa2b8b9424bc7827a0aebbf9f23448df4621","_id":"kafka-streams@0.23.0","_shasum":"8aba93216df8d7bd781898c3419c1a7341b8a3b6","_from":".","_npmVersion":"4.0.5","_nodeVersion":"7.4.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"shasum":"8aba93216df8d7bd781898c3419c1a7341b8a3b6","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-0.23.0.tgz","integrity":"sha512-nRNBC4FvCEWabuqhvqDF/ECoQXFGx6wpPXUsnI3u9wqEJe5Bv7K7vcCBhjT/kPPEtERFrb008UYUICeQG2cOQQ==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCICqgck4pRCVX58AVvdlqd0Q3CQNFjFLkeEyOTX7Kt5PNAiAlNoq2QprXXRv4l4fcOoU6/F2jmA5gB3WO6isKS9rA0g=="}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"_npmOperationalInternal":{"host":"packages-18-east.internal.npmjs.com","tmp":"tmp/kafka-streams-0.23.0.tgz_1492870221727_0.7716164465527982"},"directories":{}},"0.24.0":{"name":"kafka-streams","version":"0.24.0","description":"kafka-streams for nodejs","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"mocha test/unit/Observable.test.js","test-unit":"istanbul cover _mocha -- --recursive -R spec test/unit","test-int":"istanbul cover _mocha -- --recursive --timeout 12500 -R spec test/int && istanbul check-coverage --statements 60","test":"npm run test-unit && npm run test-int"},"repository":{"type":"git","url":"git+https://github.com/krystianity/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/krystianity/kafka-streams/issues"},"homepage":"https://github.com/krystianity/kafka-streams#readme","dependencies":{"bluebird":"~3.5.0","most":" ~1.2.2","most-subject":"^5.3.0","sinek":"~3.8.0"},"devDependencies":{"istanbul":"~0.4.2","log4bro":"~2.0.1","mocha":"~3.2.0","proxyquire":"~1.7.11","uuid":"~3.0.1","async":"~2.3.0"},"gitHead":"d32a730303b44fb168111bf8c1c5fd32e7299eac","_id":"kafka-streams@0.24.0","_shasum":"7f23c6a00d61fee387a9e2aa22d7b94583db5b08","_from":".","_npmVersion":"4.0.5","_nodeVersion":"7.4.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"shasum":"7f23c6a00d61fee387a9e2aa22d7b94583db5b08","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-0.24.0.tgz","integrity":"sha512-hyBddjdCFj3utXBB9ef1q3VXD5XtY5D4Ayqo7OWoYz4dfr39YuVvF5/MDm7+ZUcvYRZdI46L9Z3/sEDKJ9tF4g==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCupulL3CmmhSgTU4LE7Rc4eqzvIajowC7k/99AAZAozgIhAJwzw2ZzLbxeiWQhwONVKV/Q/yCqAO7qhaaYw1vMIIYJ"}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"_npmOperationalInternal":{"host":"packages-12-west.internal.npmjs.com","tmp":"tmp/kafka-streams-0.24.0.tgz_1492961449809_0.5197815673891455"},"directories":{}},"0.27.0":{"name":"kafka-streams","version":"0.27.0","description":"kafka-streams for nodejs","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"mocha test/unit/Observable.test.js","test-unit":"_mocha --recursive -R spec test/unit","test-int":"istanbul cover _mocha -- --recursive --timeout 12500 -R spec test/int && istanbul check-coverage --statements 60","test":"npm run test-unit && npm run test-int"},"repository":{"type":"git","url":"git+https://github.com/krystianity/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/krystianity/kafka-streams/issues"},"homepage":"https://github.com/krystianity/kafka-streams#readme","dependencies":{"bluebird":"~3.5.0","most":" ~1.2.2","most-subject":"^5.3.0","sinek":"~3.8.0"},"devDependencies":{"istanbul":"~0.4.2","log4bro":"~2.0.1","mocha":"~3.2.0","proxyquire":"~1.7.11","uuid":"~3.0.1","async":"~2.3.0"},"gitHead":"a98a5fe2f029048920336e40795b7a0745ca35c7","_id":"kafka-streams@0.27.0","_shasum":"7f00edf6a336ce0f0b7dbeb3b76e1f006112f13e","_from":".","_npmVersion":"4.0.5","_nodeVersion":"7.4.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"shasum":"7f00edf6a336ce0f0b7dbeb3b76e1f006112f13e","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-0.27.0.tgz","integrity":"sha512-Td/F2T8jz+JtcULO+BeJ1VAk7yAV8e83OCdj9HJ1hxOC//OsdlnPOODpxpTwIn3RK6RGyl/zMYFXOJZq7Cj8vQ==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDU8a0WnRr1yZjrzHrpHxMessUfp/ZkKyzWErKNZWauwwIgBKiquxF7Alm9qRMOfutovIHoXXhJNi/WqbwARReJMzk="}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"_npmOperationalInternal":{"host":"packages-18-east.internal.npmjs.com","tmp":"tmp/kafka-streams-0.27.0.tgz_1492974997662_0.5628778454847634"},"directories":{}},"1.28.0":{"name":"kafka-streams","version":"1.28.0","description":"kafka-streams for nodejs","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"mocha test/unit/Observable.test.js","test-unit":"_mocha --recursive -R spec test/unit","test-int":"istanbul cover _mocha -- --recursive --timeout 12500 -R spec test/int && istanbul check-coverage --statements 60","test":"npm run test-unit && npm run test-int"},"repository":{"type":"git","url":"git+https://github.com/krystianity/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/krystianity/kafka-streams/issues"},"homepage":"https://github.com/krystianity/kafka-streams#readme","dependencies":{"bluebird":"~3.5.0","most":" ~1.2.2","most-subject":"^5.3.0","sinek":"~3.8.0"},"devDependencies":{"istanbul":"~0.4.2","log4bro":"~2.0.1","mocha":"~3.2.0","proxyquire":"~1.7.11","uuid":"~3.0.1","async":"~2.3.0"},"gitHead":"f3370ba3b2ea2a60b6f56e73e4d3f7d006c94fe0","_id":"kafka-streams@1.28.0","_shasum":"4cd3968412a3cbcd88f4d96894baf4d475c2ff38","_from":".","_npmVersion":"4.0.5","_nodeVersion":"7.4.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"shasum":"4cd3968412a3cbcd88f4d96894baf4d475c2ff38","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-1.28.0.tgz","integrity":"sha512-FHcYcPyPWHdf+GKIldt33phlbLKAyi7ZdX8DYMyqTUN9sPEg9T56ODZTZjt08bZ+1d/qENGRxOz1xx/dfbMd2Q==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQCLi9CAekOWE+dFwFcXfrhK/iW1VNa99WYMcH9QfAj5ZQIgNCK2bCTudryKmENdF36e/NMX2kEF6LeILgmMUBpf1SU="}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"_npmOperationalInternal":{"host":"packages-12-west.internal.npmjs.com","tmp":"tmp/kafka-streams-1.28.0.tgz_1492978665762_0.9259035133291036"},"directories":{}},"1.30.0":{"name":"kafka-streams","version":"1.30.0","description":"kafka-streams for nodejs","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"mocha test/unit/Observable.test.js","test-unit":"_mocha --recursive -R spec test/unit","test-int":"istanbul cover _mocha -- --recursive --timeout 12500 -R spec test/int && istanbul check-coverage --statements 60","test":"npm run test-unit && npm run test-int","jsdoc":"rm -r ./docs/jsdoc && jsdoc ./lib --recurse -R ./README.md -d ./docs/jsdoc","jsdoc2md":"rm ./docs/doc.md && jsdoc2md -f ./lib/**/*.js -d > ./docs/doc.md","docs":"npm run jsdoc && npm run jsdoc2md"},"repository":{"type":"git","url":"git+https://github.com/krystianity/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/krystianity/kafka-streams/issues"},"homepage":"https://github.com/krystianity/kafka-streams#readme","dependencies":{"bluebird":"~3.5.0","most":"~1.3.0","most-subject":"^5.3.0","sinek":"~3.8.0"},"devDependencies":{"istanbul":"~0.4.2","log4bro":"~2.0.1","mocha":"~3.3.0","proxyquire":"~1.7.11","uuid":"~3.0.1","async":"~2.4.0","jsdoc":"~3.4.3","jsdoc-to-markdown":"~3.0.0"},"gitHead":"37f3fa119ea9c0728ff999be2b88dcbd6f7624a5","_id":"kafka-streams@1.30.0","_shasum":"3c3561b5729c3f10eb5809e354b6388a2feea74b","_from":".","_npmVersion":"4.0.5","_nodeVersion":"7.4.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"shasum":"3c3561b5729c3f10eb5809e354b6388a2feea74b","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-1.30.0.tgz","integrity":"sha512-9mrmW6MT1rkj2+brIGSCSySMji6afIYyWDhszKWsKegE+1/AneuIdy9d34s0cPaHEaxR601CeE8Q1pKhtiWUUA==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCPLZDbCFe0C4t+sGHCc2SMFgDB5afNlaHGQ7wPsqTuLQIhAP1NhiCEHZm5x10E23UwHY4xejwVxjFpp1J06Zm9WTI+"}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"_npmOperationalInternal":{"host":"packages-18-east.internal.npmjs.com","tmp":"tmp/kafka-streams-1.30.0.tgz_1493579114064_0.6021524670068175"},"directories":{}},"1.31.0":{"name":"kafka-streams","version":"1.31.0","description":"kafka-streams for nodejs","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"mocha test/unit/Observable.test.js","test-unit":"_mocha --recursive -R spec test/unit","test-int":"istanbul cover _mocha -- --recursive --timeout 12500 -R spec test/int && istanbul check-coverage --statements 60","test":"npm run test-unit && npm run test-int","jsdoc":"rm -r ./docs/jsdoc && jsdoc ./lib --recurse -R ./README.md -d ./docs/jsdoc","jsdoc2md":"rm ./docs/doc.md && jsdoc2md -f ./lib/**/*.js -d > ./docs/doc.md","docs":"npm run jsdoc && npm run jsdoc2md"},"repository":{"type":"git","url":"git+https://github.com/krystianity/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/krystianity/kafka-streams/issues"},"homepage":"https://github.com/krystianity/kafka-streams#readme","dependencies":{"bluebird":"~3.5.0","most":"~1.3.0","most-subject":"^5.3.0","sinek":"~3.8.0"},"devDependencies":{"istanbul":"~0.4.2","log4bro":"~2.0.1","mocha":"~3.3.0","proxyquire":"~1.7.11","uuid":"~3.0.1","async":"~2.4.0","jsdoc":"~3.4.3","jsdoc-to-markdown":"~3.0.0"},"gitHead":"33f72f03bfa6e8707b1f51082489c10141fdaf41","_id":"kafka-streams@1.31.0","_shasum":"355211640169029598f9ab9a0b4822e5ff583f78","_from":".","_npmVersion":"4.0.5","_nodeVersion":"7.4.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"shasum":"355211640169029598f9ab9a0b4822e5ff583f78","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-1.31.0.tgz","integrity":"sha512-hzJBzkk4Rv+H07jZtE8dIwN9mNyWkdwEbaPhDMdxSAk/hOBt+A9shZoT2RsvDwsRIGmHRqdxn51NW1W0AGjc0w==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIDExs24rWZGWOiZCQXCY+1OZLXTldAUEG2OamiOJETGAAiAy7FqXsEhDZ21hopXeJREB5oHaKTtly/g5tXEud3jgnw=="}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"_npmOperationalInternal":{"host":"packages-18-east.internal.npmjs.com","tmp":"tmp/kafka-streams-1.31.0.tgz_1493584449881_0.39950099820271134"},"directories":{}},"1.31.1":{"name":"kafka-streams","version":"1.31.1","description":"kafka-streams for nodejs","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"mocha test/unit/Observable.test.js","test-unit":"_mocha --recursive -R spec test/unit","test-int":"istanbul cover _mocha -- --recursive --timeout 12500 -R spec test/int && istanbul check-coverage --statements 60","test":"npm run test-unit && npm run test-int","jsdoc":"rm -r ./docs/jsdoc && jsdoc ./lib --recurse -R ./README.md -d ./docs/jsdoc","jsdoc2md":"rm ./docs/doc.md && jsdoc2md -f ./lib/**/*.js -d > ./docs/doc.md","docs":"npm run jsdoc && npm run jsdoc2md"},"repository":{"type":"git","url":"git+https://github.com/nodefluent/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/nodefluent/kafka-streams/issues"},"homepage":"https://github.com/nodefluent/kafka-streams#readme","dependencies":{"bluebird":"~3.5.0","most":"~1.3.0","most-subject":"^5.3.0","sinek":"~3.8.0"},"devDependencies":{"istanbul":"~0.4.2","log4bro":"~2.0.1","mocha":"~3.3.0","proxyquire":"~1.7.11","uuid":"~3.0.1","async":"~2.4.0","jsdoc":"~3.4.3","jsdoc-to-markdown":"~3.0.0"},"gitHead":"0c1bf18e8ad19b209a41f520a35756d3f11743de","_id":"kafka-streams@1.31.1","_shasum":"33dfede969ad1d6f2e8d104e0194c2a24e369e22","_from":".","_npmVersion":"4.0.5","_nodeVersion":"7.4.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"shasum":"33dfede969ad1d6f2e8d104e0194c2a24e369e22","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-1.31.1.tgz","integrity":"sha512-l0UD6ckonX8krba9fnNYAbqXgXFsa32fgvyeC2a5j88JR1P9PqZuCtSnQxnT1oH4cD0XBOjCIzVqyRg5qFId9Q==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIFPJg6CsnTICsfaxdm4yocWr14+7DUAYJoT4x0lvjlt8AiB0k2hvim35yhvMZ87UPFL0uBuf2FiXpdtuW9B0CfQmBg=="}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"_npmOperationalInternal":{"host":"packages-12-west.internal.npmjs.com","tmp":"tmp/kafka-streams-1.31.1.tgz_1494704979052_0.5493837497197092"},"directories":{}},"1.32.0":{"name":"kafka-streams","version":"1.32.0","description":"kafka-streams for nodejs","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"mocha test/unit/Observable.test.js","test-unit":"_mocha --recursive -R spec test/unit","test-int":"istanbul cover _mocha -- --recursive --timeout 12500 -R spec test/int && istanbul check-coverage --statements 60","test":"npm run test-unit && npm run test-int","jsdoc":"rm -r ./docs/jsdoc && jsdoc ./lib --recurse -R ./README.md -d ./docs/jsdoc","jsdoc2md":"rm ./docs/doc.md && jsdoc2md -f ./lib/**/*.js -d > ./docs/doc.md","docs":"npm run jsdoc && npm run jsdoc2md"},"repository":{"type":"git","url":"git+https://github.com/nodefluent/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/nodefluent/kafka-streams/issues"},"homepage":"https://github.com/nodefluent/kafka-streams#readme","dependencies":{"bluebird":"~3.5.0","most":"~1.3.0","most-subject":"^5.3.0","sinek":"~3.8.0"},"devDependencies":{"istanbul":"~0.4.2","log4bro":"~2.0.1","mocha":"~3.4.1","proxyquire":"~1.8.0","uuid":"~3.0.1","async":"~2.4.0","jsdoc":"~3.4.3","jsdoc-to-markdown":"~3.0.0"},"gitHead":"132edfd7214692e020950af38a6d8061ef131b28","_id":"kafka-streams@1.32.0","_shasum":"dc6c9fa58ee84170485c1df7530d598a17d62f75","_from":".","_npmVersion":"4.0.5","_nodeVersion":"7.4.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"shasum":"dc6c9fa58ee84170485c1df7530d598a17d62f75","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-1.32.0.tgz","integrity":"sha512-0lUmpeingKJ8BROqTUOALdTRi7YRerHPwIYeFmqXR8Ib3S/Wb0iFM0eIuZ/099SVRN23KhiyPswzNi/7dqBNMg==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCICOGBH+HQrKxBuu9ych29+hhNa33htQ8FO6o7GLt70WGAiBrBrRJiFOtdRGtjr1uaX/f4oxsx6IiRr184XhCHdzp5w=="}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-streams-1.32.0.tgz_1495205125922_0.2544565945863724"},"directories":{}},"2.1.0":{"name":"kafka-streams","version":"2.1.0","description":"kafka-streams for nodejs","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"mocha test/unit/Observable.test.js","test-unit":"_mocha --recursive -R spec test/unit","test-int":"istanbul cover _mocha -- --recursive --timeout 12500 -R spec test/int && istanbul check-coverage --statements 60","test":"npm run test-unit && npm run test-int","jsdoc":"rm -r ./docs/jsdoc && jsdoc ./lib --recurse -R ./README.md -d ./docs/jsdoc","jsdoc2md":"rm ./docs/doc.md && jsdoc2md -f ./lib/**/*.js -d > ./docs/doc.md","docs":"npm run jsdoc && npm run jsdoc2md"},"repository":{"type":"git","url":"git+https://github.com/nodefluent/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/nodefluent/kafka-streams/issues"},"homepage":"https://github.com/nodefluent/kafka-streams#readme","dependencies":{"bluebird":"~3.5.0","most":"~1.5.0","most-subject":"^5.3.0","sinek":"~5.0.1"},"devDependencies":{"istanbul":"~0.4.2","log4bro":"~3.0.0","mocha":"~3.4.1","proxyquire":"~1.8.0","uuid":"~3.1.0","async":"~2.5.0","jsdoc":"~3.5.1","jsdoc-to-markdown":"~3.0.0"},"gitHead":"1c7ac1dc6d292ab76cce8c5c803222f3ceb47b89","_id":"kafka-streams@2.1.0","_npmVersion":"5.0.4","_nodeVersion":"8.0.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"integrity":"sha512-J2bTVBR3Db31q/rXVBPDS2aPj5uvxanEKqp7omn8FfeeDWUmR+3nD6lT3ba4DXFbHSr1KOZhyXPq403VDvrZ3Q==","shasum":"e24b4011acc50c3e3d61daac09921aaea184d944","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-2.1.0.tgz","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIBccmgc8McSYkY1rCxcjAY2C3teXGEWbuvv3p+sHIn5mAiBkOm0ngNkq5eWbcI+3El0NtwhqA/swx63LptMmwzcukw=="}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-streams-2.1.0.tgz_1499897832816_0.6429959386587143"},"directories":{}},"2.2.0":{"name":"kafka-streams","version":"2.2.0","description":"kafka-streams for nodejs","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"mocha test/unit/Observable.test.js","test-unit":"_mocha --recursive -R spec test/unit","test-int":"istanbul cover _mocha -- --recursive --timeout 12500 -R spec test/int && istanbul check-coverage --statements 60","test":"npm run test-unit && npm run test-int","jsdoc":"rm -r ./docs/jsdoc && jsdoc ./lib --recurse -R ./README.md -d ./docs/jsdoc","jsdoc2md":"rm ./docs/doc.md && jsdoc2md -f ./lib/**/*.js -d > ./docs/doc.md","docs":"npm run jsdoc && npm run jsdoc2md"},"repository":{"type":"git","url":"git+https://github.com/nodefluent/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/nodefluent/kafka-streams/issues"},"homepage":"https://github.com/nodefluent/kafka-streams#readme","dependencies":{"bluebird":"~3.5.0","most":"~1.5.0","most-subject":"^5.3.0","sinek":"^5.2.0"},"devDependencies":{"async":"~2.5.0","istanbul":"~0.4.2","jsdoc":"^3.5.3","jsdoc-to-markdown":"~3.0.0","log4bro":"~3.0.0","mocha":"~3.4.1","proxyquire":"~1.8.0","uuid":"~3.1.0"},"gitHead":"4165b5454f040c1d28fcf54274cd1d25a06612d3","_id":"kafka-streams@2.2.0","_npmVersion":"5.3.0","_nodeVersion":"8.2.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"integrity":"sha512-Hn1L0E0orKlav57D+s5BXMkIeKEQGfi5VB9AfxPATi+A8QSVDE87QEhGoWtbCkMBYY1pkJj0vCZ2NTxTdNne3A==","shasum":"60156d3cebbb70e3f00c9a38d65f5921f5b16e85","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-2.2.0.tgz","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCLVZiiu8+feruIg4sB4si9t+AXgFzIlFJkAFqaIOt4vwIhANjNVXv8rFqFMts0iQqk3WRVryYy5jQwbDsme4ufa+Aa"}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-streams-2.2.0.tgz_1501280639119_0.7892504965420812"},"directories":{}},"2.3.0":{"name":"kafka-streams","version":"2.3.0","description":"kafka-streams for nodejs","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"mocha test/unit/Observable.test.js","test-unit":"_mocha --recursive -R spec test/unit","test-int":"istanbul cover _mocha -- --recursive --timeout 12500 -R spec test/int && istanbul check-coverage --statements 60","test":"npm run test-unit && npm run test-int","jsdoc":"rm -r ./docs/jsdoc && jsdoc ./lib --recurse -R ./README.md -d ./docs/jsdoc","jsdoc2md":"rm ./docs/doc.md && jsdoc2md -f ./lib/**/*.js -d > ./docs/doc.md","docs":"npm run jsdoc && npm run jsdoc2md"},"repository":{"type":"git","url":"git+https://github.com/nodefluent/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/nodefluent/kafka-streams/issues"},"homepage":"https://github.com/nodefluent/kafka-streams#readme","dependencies":{"bluebird":"~3.5.0","most":"~1.6.0","most-subject":"^5.3.0","sinek":"^5.4.0"},"devDependencies":{"async":"~2.5.0","istanbul":"~0.4.2","jsdoc":"^3.5.3","jsdoc-to-markdown":"~3.0.0","log4bro":"~3.0.0","mocha":"~3.5.0","proxyquire":"~1.8.0","uuid":"~3.1.0"},"gitHead":"d95d4ee3da8af62d5954c9f7451e16ad8e4320c6","_id":"kafka-streams@2.3.0","_npmVersion":"5.3.0","_nodeVersion":"8.4.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"integrity":"sha512-x7qwGWseRRlnadwmtzR2LkJNJ7k9ovDTZ1e1zEYPOmnUv9F4kn+66X0hQYqZ7FNd5+RcXQdxSStWB/D54+PFIw==","shasum":"8377ac166a2572d120ef3034099d367aa80c3daa","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-2.3.0.tgz","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIAULpJZdfD1rfLmsoIIua4NOWHlpKykehLYRB4/vysjpAiEApKRVskv6pktp69en56F3Wfrfjo+sZT0WZu/85kZII6s="}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-streams-2.3.0.tgz_1503433062708_0.4288494710344821"},"directories":{}},"3.0.0":{"name":"kafka-streams","version":"3.0.0","description":"kafka-streams for Node.js","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"mocha test/unit/Observable.test.js","test-unit":"_mocha --recursive -R spec test/unit","test-int":"istanbul cover _mocha -- --recursive --timeout 12500 --exit -R spec test/int/ && istanbul check-coverage --statements 60","test":"npm run test-unit && npm run test-int","jsdoc":"rm -r ./docs/jsdoc && jsdoc ./lib --recurse -R ./README.md -d ./docs/jsdoc","jsdoc2md":"rm ./docs/doc.md && jsdoc2md -f ./lib/**/*.js -d > ./docs/doc.md","docs":"npm run jsdoc && npm run jsdoc2md"},"repository":{"type":"git","url":"git+https://github.com/nodefluent/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/nodefluent/kafka-streams/issues"},"homepage":"https://github.com/nodefluent/kafka-streams#readme","dependencies":{"bluebird":"~3.5.0","debug":"^3.1.0","most":"^1.7.2","most-subject":"^5.3.0","sinek":"^6.2.2"},"devDependencies":{"async":"~2.5.0","istanbul":"~0.4.5","jsdoc":"^3.5.5","jsdoc-to-markdown":"~3.0.0","log4bro":"~3.1.1","mocha":"~4.0.0","proxyquire":"~1.8.0","uuid":"~3.1.0"},"gitHead":"9ca47617d89df43d0dcfe0d921b35227d2ac3420","_id":"kafka-streams@3.0.0","_npmVersion":"5.3.0","_nodeVersion":"8.6.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"integrity":"sha512-RHVWh9JHqOFxq1ZHm4iK1D1H+iH+Dr41Qfez5dg/JMn7l0h81OtdezPH++p6qxQU5JuRwMeBZubseDBuXZpFXg==","shasum":"b228c6f6db4f89b245a8ae0a0c2163279a598a52","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-3.0.0.tgz","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIADJP37TVXGXfJMAT2H0BcAb4kgKBZ5cO5+Z+fNBNm19AiEA352u/P9qNjUqmcV+MicjoVvAQea1O61NMJnQFgq5zgg="}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-streams-3.0.0.tgz_1507053931248_0.03130782279185951"},"directories":{}},"4.0.0":{"name":"kafka-streams","version":"4.0.0","description":"kafka-streams for Node.js","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"_mocha test/unit/Observable.test.js","test-unit":"_mocha --recursive --exit -R spec test/unit","test-int":"_mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:debug":"DEBUG=sinek:*,kafka-streams:* _mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:cov":"istanbul cover _mocha -- --recursive --timeout 22500 --exit -R spec test/int/ && istanbul check-coverage --statements 60","test":"npm run test-unit && npm run test-int","jsdoc":"rm -r ./docs/jsdoc && jsdoc ./lib --recurse -R ./README.md -d ./docs/jsdoc","jsdoc2md":"rm ./docs/doc.md && jsdoc2md -f ./lib/**/*.js -d > ./docs/doc.md","docs":"npm run jsdoc && npm run jsdoc2md","kafka:start":"./kafka-setup/start.sh","kafka:stop":"./kafka-setup/stop.sh","kafka:logs":"docker-compose --file ./kafka-setup/docker-compose.yml logs -f"},"repository":{"type":"git","url":"git+https://github.com/nodefluent/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/nodefluent/kafka-streams/issues"},"homepage":"https://github.com/nodefluent/kafka-streams#readme","dependencies":{"bluebird":"~3.5.1","debug":"~3.1.0","most":"~1.7.3","most-subject":"~6.0.0","sinek":"~6.15.2"},"devDependencies":{"async":"~2.6.0","jsdoc":"~3.5.5","jsdoc-to-markdown":"~4.0.1","log4bro":"~3.7.0","mocha":"~5.1.1","proxyquire":"~2.0.1","uuid":"~3.2.1"},"gitHead":"01c82cd3cf6128b377d4f37ac749c0734768efdc","_id":"kafka-streams@4.0.0","_npmVersion":"5.7.1","_nodeVersion":"9.8.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"integrity":"sha512-acFn7fJwYGPLtV6Dtm3jluOqWtsbAZxKoxS6yqZ+m6svlye9L7Ue3PHqW9akhWmVQpXOgzxsZOEAhw1LEsehkQ==","shasum":"d56a4b87186fd3a050001594b0ab185817a893ee","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-4.0.0.tgz","fileCount":27,"unpackedSize":198535,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJa3RePCRA9TVsSAnZWagAAikAQAIu/8Bt36bYXVFDJmR/U\ntLHrl48i1GXmOLTcpT6xfwGgalb/QKIawzqNRSEbhxsgN1in7//ZG5dYI1Xp\n1omYr38GpWdbHkXZqKPy+QphqzWzdumnhO261UBDikGeWE3tBtmZb56yPmdw\nXa/W5xiDYd/Itmge56nrix05Ci0NPK3L9oLTiFr0jHRP5QBFdNzK3T1HW45X\nUsyMEwdovdlX2Lnx5uxNtJ36OiX7MtpbgvvUL89j6BO3I6wqflJmtn2bV7HN\no1/MFdZNSO4x8yXuxJXlcpQ3k4vZ8PhaPjGsAPwe/j3ln2ysxJVigPDt6pQH\nMpLP3UHl+GlT6A/H8bQw9W/TADapaXA93yTu4SBV7xfpKfDTTdRtmKalkHdU\nyHuNE2YKVImb3eM2LinIwD5OQIBPUf9294uKqiwd5fEvCobD9i2/RtJeEr/Y\neGmFJpIXBs9sP9aznLyZK6PJ5TTl4M0M2Sa/TRk68LjKEEGE+qUZ8Qx3lhxQ\nUDdcCky3Cns6uOuMi4//HejmPhHHH5ci24R/PvgX7xkzn0/deCxBHh9WAoou\nyQygANGT8TA9I1cvAEOXQ1ws6ZsFL/Tv0IxVfCd/F4l6fDm4RESDNEhxV8ul\n3yFkw/V2YNr5M5Dr71mCwsiHRff8dg5WNGMVuL85HCfp5JI4HAifyS4iNArb\nWp+Q\r\n=WDp5\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIAhMSEyGfBI/43qbgTTpHOuqmOQjf0dPUVYDXPqDhDavAiEAiCkOneR7QKwaLYOS/Tklmo6WzIq7iY9dibrfxpAqf0I="}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-streams_4.0.0_1524438925677_0.9830909862387092"},"_hasShrinkwrap":false},"4.0.1":{"name":"kafka-streams","version":"4.0.1","description":"kafka-streams for Node.js","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"_mocha test/unit/Observable.test.js","test-unit":"_mocha --recursive --exit -R spec test/unit","test-int":"_mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:debug":"DEBUG=sinek:*,kafka-streams:* _mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:cov":"istanbul cover _mocha -- --recursive --timeout 22500 --exit -R spec test/int/ && istanbul check-coverage --statements 60","test":"npm run test-unit && npm run test-int","jsdoc":"rm -r ./docs/jsdoc && jsdoc ./lib --recurse -R ./README.md -d ./docs/jsdoc","jsdoc2md":"rm ./docs/doc.md && jsdoc2md -f ./lib/**/*.js -d > ./docs/doc.md","docs":"npm run jsdoc && npm run jsdoc2md","kafka:start":"./kafka-setup/start.sh","kafka:stop":"./kafka-setup/stop.sh","kafka:logs":"docker-compose --file ./kafka-setup/docker-compose.yml logs -f"},"repository":{"type":"git","url":"git+https://github.com/nodefluent/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/nodefluent/kafka-streams/issues"},"homepage":"https://github.com/nodefluent/kafka-streams#readme","dependencies":{"bluebird":"~3.5.1","debug":"~3.1.0","most":"~1.7.3","most-subject":"~6.0.0","sinek":"~6.15.2"},"devDependencies":{"async":"~2.6.0","jsdoc":"~3.5.5","jsdoc-to-markdown":"~4.0.1","log4bro":"~3.7.0","mocha":"~5.1.1","proxyquire":"~2.0.1","uuid":"~3.2.1"},"gitHead":"4f029bc43d38d5efd7c1f635cd8673ac07dcb63d","_id":"kafka-streams@4.0.1","_npmVersion":"5.7.1","_nodeVersion":"9.8.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"integrity":"sha512-SiDbCCoyeeCs2/zEFnZaEbwFPXrvhnO49tOBrqHjizfR52wejfGhpRst3wYWeJSWj6mb3ZTJyUHAxQ/cg05tzw==","shasum":"9b45bd950a35e2d4aca72ceccc1bc967d41c396e","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-4.0.1.tgz","fileCount":27,"unpackedSize":198680,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJa3fqxCRA9TVsSAnZWagAA4sMP/AuzLPwgs62qm3jBXijc\n7CNUUOBNFEXlmwvBCA6IGyX1ls6C9v13R2KYZU7LeuhVP9c8nq+xwrR2xdWV\neZyohALmj+TKh6+/D+GxsZtg0pPKwk3nqe51ZjAq/a2hLWAH6t1dwZZ07ZWx\nUr08PaYHybojCnJ1sZZi3qJVdoQr07EtdJvWGVXWrP+Wjt721xdm/Q3tEhft\na9+/SvEjB/rnBw3Gb+yytyVl2cN7S/k9qo47r2FPMRCbHbyfZhmzSSn5nFRh\nbShV/vvhfRytj9gKVtWpdQHH3ETEZYCgpwkvT4pQ1aezyNsSRHACT0UlV9Sh\negYL0AXvNdLO4ar0NfCKns4+3DGPLU3Zlo/WsiRAcZPXkBW74naxpuOEVqpg\nsmmRBisY3v/dy4EdSW4hE9PL9jvSt7rvJ708gvKykJgYPFG/IxxfL0DAcXWe\natMc2cT2GqkAlTJyBOoJez60iSiOgzUgnWhRlcFc3qCG6g4jGrRmoiebFf6O\n78K4pAlTgKj+doc0dhQSbBBQNGV763+m/XcAv2CG4zY9bwY3MtOJQ7XuXrfS\nViApNU+IzJ0pSY7xuqPqLymIbeO1lfdO+8GjpJWjPAStjsDjE54wqPQS4JQ/\np+l1uL3fDZTIQ8nJmdRt+uWfxDBdnBVyCaCDaupI3A+Co1mVJ8NE48Tr0Upr\n7dr9\r\n=AaFO\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIHk7zNvS8OX6dZa3sEO8K85eTJs1Ujb/F52MeM3cR9dxAiEA51XzWMrmLYvcrB7A033ni831kjIGQlysifii4Hu/mLE="}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-streams_4.0.1_1524497072609_0.8812539321738153"},"_hasShrinkwrap":false},"4.1.0":{"name":"kafka-streams","version":"4.1.0","description":"kafka-streams for Node.js","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"_mocha test/unit/Observable.test.js","test-unit":"_mocha --recursive --exit -R spec test/unit","test-int":"_mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:debug":"DEBUG=sinek:*,kafka-streams:* _mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:cov":"istanbul cover _mocha -- --recursive --timeout 22500 --exit -R spec test/int/ && istanbul check-coverage --statements 60","test":"npm run test-unit && npm run test-int","jsdoc":"rm -r ./docs/jsdoc && jsdoc ./lib --recurse -R ./README.md -d ./docs/jsdoc","jsdoc2md":"rm ./docs/doc.md && jsdoc2md -f ./lib/**/*.js -d > ./docs/doc.md","docs":"npm run jsdoc && npm run jsdoc2md","kafka:start":"./kafka-setup/start.sh","kafka:stop":"./kafka-setup/stop.sh","kafka:logs":"docker-compose --file ./kafka-setup/docker-compose.yml logs -f"},"repository":{"type":"git","url":"git+https://github.com/nodefluent/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/nodefluent/kafka-streams/issues"},"homepage":"https://github.com/nodefluent/kafka-streams#readme","dependencies":{"bluebird":"~3.5.1","debug":"~3.1.0","most":"~1.7.3","most-subject":"~6.0.0","sinek":"~6.15.2"},"devDependencies":{"async":"~2.6.0","jsdoc":"~3.5.5","jsdoc-to-markdown":"~4.0.1","log4bro":"~3.7.0","mocha":"~5.1.1","proxyquire":"~2.0.1","uuid":"~3.2.1"},"gitHead":"045d0c25104edd793f59a39995cfc89c7964f749","_id":"kafka-streams@4.1.0","_npmVersion":"5.7.1","_nodeVersion":"9.8.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"integrity":"sha512-/QeCwR0j5Arefzdt0lqrATMoxmqHZEAvBG8XenT+KcezD+KI8Omq9BgVPmmJ2IsJvuJCD0lO95QFSJZDhV1ZXg==","shasum":"7914c47df4341bacf018ee741908f387b66e2413","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-4.1.0.tgz","fileCount":27,"unpackedSize":201762,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJa3gs0CRA9TVsSAnZWagAALzcQAKGfYqcl30gLGV0c7GAU\nePtZHXbTg+6wH1mQ5PZj8I1x3Ey+TKuzuIZY80aYg5G0Td3sW0PcWJU0YzVj\nMviLogWbEQn6W1LCQuLf5zKHST1mL7SMuKCCX+RX9lMn5NYSmtq9pzG1jfqX\noJKf0RWAaPBw+GIsH51+gJtG3pQ+wnLpRUSMx9tvxWaLk7Gn7dNjIX6pMzIC\nc4NJSlG3OUOKIvumYlCbBuReJcXmHwdl4JRDJhE1VvG100jjUhuxb4OOWAF9\n5BS8E11QuqhyjIIu2fd3TEAFkdh08EsP6AX+N+QedpJvT7R3/bZ3jxlD1d/F\numqs2Dq+UDOsJJk8IySHlj6wvPf1HaTeqt1nNhEi0dSgku3/8RfN8I7I2G/I\nkhHBITEYzlCQCqbsAVBcHGTit8o2UyOt02RJiQuAa6j+/AufVmwmPxhwqvNB\nAVnwjPMxnFYus0zL/5NwikGTNNOgMNS1xaB5A2Fq8X9WVolUoZXp5XS8Fu9r\n0w0fgyqhJ9EY1Ujuq4qbqR/ZHm+KAVEAZ57lESmvz6iZ7w7jALumLK8tpPLD\nsi2500/u4CeoR1JxVqmlqNJZG++XLNTyDobWN1sTn/zIIam6lJGn1QyrQWeL\nrP9jzrPj4VYi79NlfP1VH7yBQl0480EEPVUqo8gMrogoWXmeOl9USGQqbqM8\n7iFG\r\n=8oWE\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIBoUxvX0Xv7o1jRNYSU0KzExM0qv/x4pz4lxCySSx9ciAiEAhT90ymLrCuKVbIU/hcwyck3te8WslhY8XVMl2uRuli0="}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-streams_4.1.0_1524501299777_0.38988004851893"},"_hasShrinkwrap":false},"4.2.0":{"name":"kafka-streams","version":"4.2.0","description":"kafka-streams for Node.js","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"_mocha test/unit/Observable.test.js","test-unit":"_mocha --recursive --exit -R spec test/unit","test-int":"_mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:debug":"DEBUG=sinek:*,kafka-streams:* _mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:cov":"istanbul cover _mocha -- --recursive --timeout 22500 --exit -R spec test/int/ && istanbul check-coverage --statements 60","test":"npm run test-unit && npm run test-int","jsdoc":"rm -r ./docs/jsdoc && jsdoc ./lib --recurse -R ./README.md -d ./docs/jsdoc","jsdoc2md":"rm ./docs/doc.md && jsdoc2md -f ./lib/**/*.js -d > ./docs/doc.md","docs":"npm run jsdoc && npm run jsdoc2md","kafka:start":"./kafka-setup/start.sh","kafka:stop":"./kafka-setup/stop.sh","kafka:logs":"docker-compose --file ./kafka-setup/docker-compose.yml logs -f"},"repository":{"type":"git","url":"git+https://github.com/nodefluent/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/nodefluent/kafka-streams/issues"},"homepage":"https://github.com/nodefluent/kafka-streams#readme","dependencies":{"bluebird":"~3.5.1","debug":"~3.1.0","most":"~1.7.3","most-subject":"~6.0.0","sinek":"~6.15.2"},"devDependencies":{"async":"~2.6.0","jsdoc":"~3.5.5","jsdoc-to-markdown":"~4.0.1","log4bro":"~3.7.0","mocha":"~5.1.1","proxyquire":"~2.0.1","uuid":"~3.2.1"},"gitHead":"40d54832226488692249629464568551c18a044e","_id":"kafka-streams@4.2.0","_npmVersion":"6.0.0","_nodeVersion":"9.8.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"integrity":"sha512-ceKCTsqAUa78SjTF0lSY2uyMCaA0xnqcYlz8Rv4OO1/Cf8hpgR8SuiEBrawsrjXufR1rx3aSe94sbEE6mvTdng==","shasum":"6ca6a3b1c9d9ab00602cb7c4987aabe252d1d5db","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-4.2.0.tgz","fileCount":27,"unpackedSize":202121,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJa/oGOCRA9TVsSAnZWagAARY8P/1ACkSZSxS7AnJKuanit\nh+OukeZLWKrYeGTMqZww6KGVac8tynnbXlg0z2yd5IO/AV/g0zRYAFSefZM8\nyNVO5bmLLqNfbMqeQSAy4j7OhCBCVbbuiPCfIuSmIhI7JQNWwPaxGZmQF0G+\nO0Q5yavADBc6o9Nf63mGLlvCZ1el2/TwVDL6c74dmrLyqStnYRTUyCXw3g4l\noxt91n+U0klUW4Cy2mpbcRBu/TP98EyIk+98EYGOzvMN879f1kIdgwHJJjxv\n+zvfJjAJ7270LEOReDo4mL5IMM6J/Q0hNFRuPZQ9dHECvrhcY/eysNcQulkt\ndY18tSBxYElwtYNa88I8vIpzOumc2aVQ24J7PSXSMi7z9UZwHrRRoEA4NrMb\nQv+pXauftU2sjYaxHYVy8Pw5y7/X2w+dTLWvsMoZ1uuo3sdJxF4IKlWuNfIy\nOdDpkqcfqUiOz0X/7agbmVYAKbQY8M5/Bfk4k3IvQ1AHAOOddcVl6E7cAGhg\nJqnT6Dq72aTlOg4vEGE+g52DemYKx359oUHOAIk9io07wI2hu5yezRcsDKFp\nyqXTPN80xNC4VJrD9EkQKP1PEX1tviI1shdbfFubs94raIOTq5ra87OQIXPH\nJQr+Vki0vbErkGhtNve+GlYIFJmEz0eGs7bgHsVuY3HEhxR2httDhW04+wxQ\nfx7S\r\n=/TXO\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQCHbg+OLUJl5hgnl2o2Uq7bJAYt5dL5hIRK6ZN+qz7oGQIgJxGDtmfozprJj8Db6gbwnfrP1+fWy5egBXo2mk0UKqw="}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-streams_4.2.0_1526628749316_0.2836729933316402"},"_hasShrinkwrap":false},"4.3.0":{"name":"kafka-streams","version":"4.3.0","description":"kafka-streams for Node.js","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"_mocha test/unit/Observable.test.js","test-unit":"_mocha --recursive --exit -R spec test/unit","test-int":"_mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:debug":"DEBUG=sinek:*,kafka-streams:* _mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:cov":"istanbul cover _mocha -- --recursive --timeout 22500 --exit -R spec test/int/ && istanbul check-coverage --statements 60","test":"npm run test-unit && npm run test-int","jsdoc":"rm -r ./docs/jsdoc && jsdoc ./lib --recurse -R ./README.md -d ./docs/jsdoc","jsdoc2md":"rm ./docs/doc.md && jsdoc2md -f ./lib/**/*.js -d > ./docs/doc.md","docs":"npm run jsdoc && npm run jsdoc2md","kafka:start":"./kafka-setup/start.sh","kafka:stop":"./kafka-setup/stop.sh","kafka:logs":"docker-compose --file ./kafka-setup/docker-compose.yml logs -f"},"repository":{"type":"git","url":"git+https://github.com/nodefluent/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/nodefluent/kafka-streams/issues"},"homepage":"https://github.com/nodefluent/kafka-streams#readme","dependencies":{"bluebird":"~3.5.1","debug":"~3.1.0","most":"~1.7.3","most-subject":"~6.0.0","sinek":"~6.15.2"},"devDependencies":{"async":"~2.6.0","jsdoc":"~3.5.5","jsdoc-to-markdown":"~4.0.1","log4bro":"~3.7.0","mocha":"~5.1.1","proxyquire":"~2.0.1","uuid":"~3.2.1"},"gitHead":"b67396911afb45b0e05f24182912b6c9a4c2e6e4","_id":"kafka-streams@4.3.0","_npmVersion":"6.0.0","_nodeVersion":"9.8.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"integrity":"sha512-hYQN5v4HXIhMpVv0DqGckEoOtATJCXUwIptXITIsqgegbTJOLq+cg/zymlmLUUqLXNu15LgSJcEwOkE5T30q7w==","shasum":"2f9dc6a482103dedc06ad2d629a24f3a097fd6be","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-4.3.0.tgz","fileCount":27,"unpackedSize":202755,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJbEEyFCRA9TVsSAnZWagAAXMYQAJuazogBkOFxlLwNOY+Y\nHQ8y2PxwLp653jpcBX0l11q/Cdq6ArWdc5xmSRvqC6r/2+SjwcgTLDpBx5gh\nJsz4dIEa1sDWdD4123Yn6SmUWMuTLouPKu2uMUMQZyO+jD61+fJfq45tiNyP\nR6sPd0fmEiZbHunN+Q77NuYwnOi+v2wLTWNGi6fwRPV+fdYAwL5TUw6tokzS\nzGO/PrQFSnBSaMfP7iERhp4V0OAZ+8mrB1H2ClyciDqbddabuIEbYF54Jhrx\nINLdHpS4plpSkSxTXxwtx+2uBjUXomU7ezWnyak2dk5/1SrWOYx6se7SYH5L\nQX4qyInKUpp3NTUdp4GP4gABpN7xtjmHJozelcS23Rqcl9nZ9DJkas+2E1Cp\nFQm1GQBHa3XqgjXmazqtFRToWEboT3TkR+POd9s/m6kE0A0NZcKRA+K5Xdcj\nn2G1+sy1OSvjQhclJxYGFw84SzFvqMdjj82RD+q3J6/xX2PkQFitXtObU4cB\nlJtS8VmN0v1IavXzedT5GAjp0aB1GYbLcdrMPU9NYxm8sBziKa7I5m6u/E8l\nXm6JjZBwtUVGRnizUsspzeneVltLk0ZONcoCbgBRO+At0CbiqGldfVl2Twt7\no6vKnarbOsyTftVVMHS5OTuuEQF5wA0Wizb+dIFB9p8/RClgxFH7cVuGGMTt\nmaTu\r\n=NSZR\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDmA6eYsRIg800FsMNbvgfsPkAcOuczY1+2nl3e7P+PoAIgK7uPkYYCrW0RLucn35DmrC28D4q4Pn39DCQj8xt6j0A="}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-streams_4.3.0_1527794819618_0.7655255816172197"},"_hasShrinkwrap":false},"4.4.0":{"name":"kafka-streams","version":"4.4.0","description":"kafka-streams for Node.js","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"_mocha test/unit/Observable.test.js","test-unit":"_mocha --recursive --exit -R spec test/unit","test-int":"_mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:debug":"DEBUG=sinek:*,kafka-streams:* _mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:cov":"istanbul cover _mocha -- --recursive --timeout 22500 --exit -R spec test/int/ && istanbul check-coverage --statements 60","test":"npm run test-unit && npm run test-int","jsdoc":"rm -r ./docs/jsdoc && jsdoc ./lib --recurse -R ./README.md -d ./docs/jsdoc","jsdoc2md":"rm ./docs/doc.md && jsdoc2md -f ./lib/**/*.js -d > ./docs/doc.md","docs":"npm run jsdoc && npm run jsdoc2md","kafka:start":"./kafka-setup/start.sh","kafka:stop":"./kafka-setup/stop.sh","kafka:logs":"docker-compose --file ./kafka-setup/docker-compose.yml logs -f"},"repository":{"type":"git","url":"git+https://github.com/nodefluent/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/nodefluent/kafka-streams/issues"},"homepage":"https://github.com/nodefluent/kafka-streams#readme","dependencies":{"bluebird":"~3.5.1","debug":"~3.1.0","most":"~1.7.3","most-subject":"~6.0.0","sinek":"~6.17.0"},"devDependencies":{"async":"~2.6.1","jsdoc":"~3.5.5","jsdoc-to-markdown":"~4.0.1","log4bro":"~3.7.1","mocha":"~5.2.0","proxyquire":"~2.0.1","uuid":"~3.2.1"},"gitHead":"480320e94ea1b07f5dab94a3114d934a28d82a09","_id":"kafka-streams@4.4.0","_npmVersion":"6.0.0","_nodeVersion":"9.8.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"integrity":"sha512-rizgH5jR/NczEb01ZrA8JmKnAQj8nr0B5gnu1skU7+HK2lFAX6UUFHCC4OzW4kQGsAwzOQgAWhwxa76xBFtuTA==","shasum":"305530a01e4b2b74236e8c5850fc6b68354889ca","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-4.4.0.tgz","fileCount":27,"unpackedSize":201637,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJbI79zCRA9TVsSAnZWagAAO+kP/1u1LgQme22rwjjOficp\nCvUv/gh0HzJrJbK/20G8bENAIpNL1t8h4OrMccF1vozB5EwAQnKRkPuji73S\nXGuJfQbFP/IKzn2djal/BW0+g3Rd11fdAI0QAHqIL1/484SlnzBCe5WJf7qb\nsPOWVZAKOLgLg3yeVzsru21KPed2nMrh1AdcOOucjdAQVmO5B4Ltop89n7Bx\nyZL3zh4DI3TGNnn4elhrCvEHbVhLHEtqkJ3JiZlvPvl7EDU/EEPnDY1zEB0G\nFkuqx+Uibo6gFkmi9ZaQYs5ah7Yz+BUwSs4c8D+oDBHRfU7+CVEEFNfkleM4\n5JD/z3ofh5Mp7i8+8NKhTMlRsqGGWQTPpAcP1k5ofFehhFY9Uwz99lfQDp/0\nOwmrWtsKf/ZqBx8E50BwGYfAbdII6FeQGKZJ9/5zwsYeziKuefK2cdcEtlvY\n/PU1byjIF/BLM+1HVaHD/2fC7CJV1tMxTrKPXZpjP3uSMonzTXwAjVMnwqfs\nnnorNlLRKuE3F5NPKgNfe/snUs1aiz2IWpfGHyIKpL6ljpmoD4FPHKXNwarJ\nDVNwN/85EG3jIFrdUHDpsztTSNMO0zm7ietzHTxJvJ4JbheNSlOxldZPP18G\nQUPiEt21Put7mf1UmWtCKIbVWeYAfWWJbXJxRlIF6OHaLgOK1Qy2ZUkvt+Uz\n/lmN\r\n=Tbxb\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIHLgsuO60xqR0sUTzd3bfLSGgQ5T+F3MpTxLqQ/YtBfIAiEAyUiqptR5w3OcMxMNBqqahqoCVmOu5thz6DY0FYUgMw8="}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-streams_4.4.0_1529069425789_0.4067563148760458"},"_hasShrinkwrap":false},"4.5.0":{"name":"kafka-streams","version":"4.5.0","description":"kafka-streams for Node.js","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"_mocha test/unit/Observable.test.js","test-unit":"_mocha --recursive --exit -R spec test/unit","test-int":"_mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:debug":"DEBUG=sinek:*,kafka-streams:* _mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:cov":"istanbul cover _mocha -- --recursive --timeout 22500 --exit -R spec test/int/ && istanbul check-coverage --statements 60","test":"npm run test-unit && npm run test-int","jsdoc":"rm -r ./docs/jsdoc && jsdoc ./lib --recurse -R ./README.md -d ./docs/jsdoc","jsdoc2md":"rm ./docs/doc.md && jsdoc2md -f ./lib/**/*.js -d > ./docs/doc.md","docs":"npm run jsdoc && npm run jsdoc2md","kafka:start":"./kafka-setup/start.sh","kafka:stop":"./kafka-setup/stop.sh","kafka:logs":"docker-compose --file ./kafka-setup/docker-compose.yml logs -f"},"repository":{"type":"git","url":"git+https://github.com/nodefluent/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/nodefluent/kafka-streams/issues"},"homepage":"https://github.com/nodefluent/kafka-streams#readme","dependencies":{"bluebird":"~3.5.1","debug":"~3.1.0","global":"^4.3.2","most":"~1.7.3","most-subject":"~6.0.0","npm-check-updates":"^2.14.2","sinek":"~6.18.0"},"devDependencies":{"async":"~2.6.1","jsdoc":"~3.5.5","jsdoc-to-markdown":"~4.0.1","log4bro":"~3.7.1","mocha":"~5.2.0","proxyquire":"~2.0.1","uuid":"~3.3.0"},"gitHead":"1ca14e7fbc421347792268c2281b372337bda9c6","_id":"kafka-streams@4.5.0","_npmVersion":"6.1.0","_nodeVersion":"10.5.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"integrity":"sha512-1AycsgqFHro3RPixzzJyKMMBKiOomeA2WNMxFvWIkxVlPo2lKSkpahFh4AKxmMku5qxatr08m/9H5F3YcqPsVg==","shasum":"086578e062ed6cf0cddd9580c5f6baec74dd52f7","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-4.5.0.tgz","fileCount":28,"unpackedSize":361904,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJbM4n0CRA9TVsSAnZWagAALzcP/j5256q/bGh8EIPPpIl8\ntP/be9m3TzGrLYxrkDEH7BExiowKztX9NKMaPhZs3yvrzZT0bCpREKknxB/f\nBXw8rkBCvrCncHTMtX4QzzAwLrjQ7Evoe26NS63LFNomHkikjIq/RNhMZlDm\n9FCWe2AdAHRfK/y9WLnEbF6LHlPg5XAJzKWimFv/dE8/VRuDIQzRunZBu9Ur\naKXKTqz5CZSobjbvEeZWUIHae4IF/2pbusprL8qAMN1ZQnb3QicDcHT4E3B0\nwGXSz2Uy2a+UuUS2+0aRxs8tauv5Pzdi0ysu+hXYBpDr9pOCKb0XJ+78Dqcw\nRlg71N1RmguCvkZIy7W3omI0AfViSWcKV31/2VjNKMWOF2+rntKKJu3iDi8g\nL7ElylUNU8C671yLpw67JBhoHkz4Uv3WZJaGxE+toAW5X3Bz8hKV+fBa2RjK\nSpbF+a0fsgzO3J4whKyYmDrIxVXnKZNS+fFJteby+hJuxKdHJlXOC9Q7p8ho\n7m0pp+OyQJGDSnx3AdjvboNo7dFEP6+4059qoV5+IyCpStC6k06Z0G7jY3nQ\nyXTv3CLIMC2Gv4nyEJfhEeYchprO2K19fJueEMfSO3R3DwzShOXi1Et4ZAFe\ndTYVX/DkMpTAZ4Almwpx0OFF9eUZg15yoj8OFex0NBPgC+rVFSH9Xm2yUkG8\nuXlf\r\n=u6xi\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQDE0opJO2Vip1ag1zBtR8nEi6lZ4Wu5XJvIKskrIdw0TQIhAOpgI+q/oPV9kiFg6XZhGrMTY5I+x5ogta+MTv1huJZJ"}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-streams_4.5.0_1530104308044_0.6989938551405432"},"_hasShrinkwrap":false},"4.6.0":{"name":"kafka-streams","version":"4.6.0","description":"kafka-streams for Node.js","typings":"index.d.ts","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"_mocha test/unit/Observable.test.js","test-unit":"_mocha --recursive --exit -R spec test/unit","test-int":"_mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:debug":"DEBUG=sinek:*,kafka-streams:* _mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:cov":"istanbul cover _mocha -- --recursive --timeout 22500 --exit -R spec test/int/ && istanbul check-coverage --statements 60","test":"npm run test-unit && npm run test-int","jsdoc":"rm -r ./docs/jsdoc && jsdoc ./lib --recurse -R ./README.md -d ./docs/jsdoc","jsdoc2md":"rm ./docs/doc.md && jsdoc2md -f ./lib/**/*.js -d > ./docs/doc.md","docs":"npm run jsdoc && npm run jsdoc2md","kafka:start":"./kafka-setup/start.sh","kafka:stop":"./kafka-setup/stop.sh","kafka:logs":"docker-compose --file ./kafka-setup/docker-compose.yml logs -f","ts":"tsc ./index.d.ts"},"repository":{"type":"git","url":"git+https://github.com/nodefluent/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/nodefluent/kafka-streams/issues"},"homepage":"https://github.com/nodefluent/kafka-streams#readme","dependencies":{"bluebird":"~3.5.2","debug":"~3.1.0","global":"^4.3.2","most":"~1.7.3","most-subject":"~6.0.0","npm-check-updates":"^2.14.2","sinek":"~6.22.0"},"devDependencies":{"async":"~2.6.1","jsdoc":"~3.5.5","jsdoc-to-markdown":"~4.0.1","log4bro":"~3.7.1","mocha":"~5.2.0","proxyquire":"~2.1.0","uuid":"~3.3.2"},"gitHead":"4516222ad8ac8af49697e3db11521bc2cad11572","_id":"kafka-streams@4.6.0","_npmVersion":"6.1.0","_nodeVersion":"10.7.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"integrity":"sha512-FZ1WWx+zfhERuZU2Io+P5V2uGyYzFxfnxbZSqOFxHqOVUioqMJCVNfIa6mNS61H/YFv2YbXvrFRme+00cXLCtA==","shasum":"df3b01aa4b781e75b0dd45537c9b84376c6194de","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-4.6.0.tgz","fileCount":28,"unpackedSize":255664,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJblwdXCRA9TVsSAnZWagAAnHUQAJFCMf0ZOKZvxbLi9Gw2\nmkoXW8B3FTl8X/o72SSeiD2jtfpCzRtVivD4EIJktcP3ZVAnKhaE5VIkQpmp\nltQb2vwm9FbqDGmqqEhHjvRY2xRXPsQXOIguCsYXzPuh6yCReUNX29jQQ6KT\ny19w/x9bqlERKa4bLZLKxkGMLzo6J3vj2BQLGLlzIicDTeMjYwSOIHdFdRxA\nrxM86ySLLcR2nZ4J8R9Ddp8sUfQbakIdFjE4Jbr6+n6Uap/y4R2Tf7IsxXXL\n++TjdklGiVDWX7fGPAPvA4o7NErv5SVshPLz9CVZeWYnzjkS/5vSHLi+roN/\ngjpxqGiKHh+/6gGlSuo424p2ph0UwMxuppq4YZZxF/rc6XRrCQLZvqBFMlfe\niBWnbOwbDG8cerTGbmxXeFcEPEVw89x+oMN/zroj4etonAfdoRfzVUv/7uL1\nTKlqxu4C/q1EhPx7B+YguqHkFhO1UBlXNbvcNKr3dg7T6R4uO1WNkGC9c34M\nG2Khh4AIWN0C43fH1V7abxXOBM5fWSy7iP8vKa1c1ht8sdywzSmKpSui5loG\nMvGxUpN+IKM7uJdjm6dzlreRSeHzZtyk7mUAwwdzMxCJa3jVt2zWwiSR2VJX\ncoh+lqocJBmrb1t8Oj/tgInxrf3pe419DkUKKuGkZxL92AKkaSojiRH7zmM6\neJgh\r\n=Lszb\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIGP8gnSAeQiN2WUs+1pxNFga81kSUuvRTWIUDaCRDFh0AiBC/mN3DrOO4EzD77Nm+KQuG+kupieZ9p9Kbhw2GqEVVA=="}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-streams_4.6.0_1536624470747_0.09729194466579338"},"_hasShrinkwrap":false},"4.6.1":{"name":"kafka-streams","version":"4.6.1","description":"kafka-streams for Node.js","typings":"index.d.ts","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"_mocha test/unit/Observable.test.js","test-unit":"_mocha --recursive --exit -R spec test/unit","test-int":"_mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:debug":"DEBUG=sinek:*,kafka-streams:* _mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:cov":"istanbul cover _mocha -- --recursive --timeout 22500 --exit -R spec test/int/ && istanbul check-coverage --statements 60","test":"npm run test-unit && npm run test-int","jsdoc":"rm -r ./docs/jsdoc && jsdoc ./lib --recurse -R ./README.md -d ./docs/jsdoc","jsdoc2md":"rm ./docs/doc.md && jsdoc2md -f ./lib/**/*.js -d > ./docs/doc.md","docs":"npm run jsdoc && npm run jsdoc2md","kafka:start":"./kafka-setup/start.sh","kafka:stop":"./kafka-setup/stop.sh","kafka:logs":"docker-compose --file ./kafka-setup/docker-compose.yml logs -f","ts":"tsc ./index.d.ts"},"repository":{"type":"git","url":"git+https://github.com/nodefluent/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/nodefluent/kafka-streams/issues"},"homepage":"https://github.com/nodefluent/kafka-streams#readme","dependencies":{"bluebird":"~3.5.2","debug":"~3.2.1","global":"^4.3.2","most":"~1.7.3","most-subject":"~6.0.0","npm-check-updates":"^2.14.2","sinek":"~6.22.0"},"devDependencies":{"async":"~2.6.1","jsdoc":"~3.5.5","jsdoc-to-markdown":"~4.0.1","log4bro":"~3.7.1","mocha":"~5.2.0","proxyquire":"~2.1.0","uuid":"~3.3.2"},"gitHead":"e275f0c48aa5ce605d980feaaed95b1d62101b8e","_id":"kafka-streams@4.6.1","_npmVersion":"6.1.0","_nodeVersion":"10.7.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"integrity":"sha512-7zUtw+wbzTA1a2wvVfguEetBNc4ELy6tyKtaoFYmYWOkyYmUhe+iU9QEjHTq8H/jgwuikpdQEVAunI0PvK33Tw==","shasum":"b9d8d764861c3539b10f7ea7f57629080ec06c35","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-4.6.1.tgz","fileCount":28,"unpackedSize":255761,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJbl5xhCRA9TVsSAnZWagAA+bUP/1yfSiO6v68D4DFCEWNb\nHAviMKxcPSa0Rp2lbfex1sZof0dP1qTzVYX3Fz4FBIViIjdxkVguJEuP8We+\n4s1umSmfKGtaL9X603kmQuQaFyq5bZoIFZJE37JVRwJl5a0lRr9Cps/APwe5\n+FtIg2id5nm+GjRMY5JhLLICfmGnI+4utVbAQnn5fROA6qQCfGDgULb9T/ks\ni6zYm47JvKvif2CGfNlAYpvM+dWBfYLPH965a+eOloAJenNbppLTp2dtJGjz\nBxstk0eB6IGBde9fM6SK4c4SJZBSB6/oKg27x5/kv54DH58mog7RPTcZoe4D\nQPT3fUN1EnQk42wCIh6+TqoGxLWgjpT4Uiz4t7g2BkxnVLHGlI+szk3Fcf0B\n3pw4zrzpzf80x/uKLp6EklQ7e/WSXnSN5TfkP9zskzpvF7KbrU/5yJHeNjkm\nHsxehc636L0LNECshFjx5ORz2Zse1SbNSCpsLBta0YDpMoeHpzXL48zKp5Eh\ntVFC4MkdxaWSul/Xa4aoJ9ifZIXPrq+EfBMu0nkz5gqQxJ6QyG/1IuFIvtRC\nxaW4FmxbfFkYNYtvLMpvJO8xo/VWSgPdFBq9ID7pHavzQyiVqXNY2jfaPc7p\ne6XuBjYVPKVeSdzVeIfhD4FQMyID3+Y7nUPq6M4xCVsQDhtOY5tqneeAHwud\nzRlb\r\n=d8fs\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQD5tB9lVO8IFrwf4jiI3cny4pswqzYRMDqvWvvt/N624AIhAMWojHjkjwaIVZs9K1v8aaMm3XN7GiMlZSTM2rzZM5Bs"}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-streams_4.6.1_1536662625099_0.6595297446440431"},"_hasShrinkwrap":false},"4.6.2":{"name":"kafka-streams","version":"4.6.2","description":"kafka-streams for Node.js","typings":"index.d.ts","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"_mocha test/unit/Observable.test.js","test-unit":"_mocha --recursive --exit -R spec test/unit","test-int":"_mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:debug":"DEBUG=sinek:*,kafka-streams:* _mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:cov":"istanbul cover _mocha -- --recursive --timeout 22500 --exit -R spec test/int/ && istanbul check-coverage --statements 60","test":"npm run test-unit && npm run test-int","jsdoc":"rm -r ./docs/jsdoc && jsdoc ./lib --recurse -R ./README.md -d ./docs/jsdoc","jsdoc2md":"rm ./docs/doc.md && jsdoc2md -f ./lib/**/*.js -d > ./docs/doc.md","docs":"npm run jsdoc && npm run jsdoc2md","kafka:start":"./kafka-setup/start.sh","kafka:stop":"./kafka-setup/stop.sh","kafka:logs":"docker-compose --file ./kafka-setup/docker-compose.yml logs -f","ts":"tsc ./index.d.ts"},"repository":{"type":"git","url":"git+https://github.com/nodefluent/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/nodefluent/kafka-streams/issues"},"homepage":"https://github.com/nodefluent/kafka-streams#readme","dependencies":{"bluebird":"~3.5.2","debug":"~4.0.1","global":"^4.3.2","most":"~1.7.3","most-subject":"~6.0.0","npm-check-updates":"^2.14.2","sinek":"~6.22.2"},"devDependencies":{"async":"~2.6.1","jsdoc":"~3.5.5","jsdoc-to-markdown":"~4.0.1","log4bro":"~3.7.1","mocha":"~5.2.0","proxyquire":"~2.1.0","uuid":"~3.3.2"},"gitHead":"5aa3f3f7398e40d6762d122d72e439e2a753a549","_id":"kafka-streams@4.6.2","_npmVersion":"6.1.0","_nodeVersion":"10.7.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"integrity":"sha512-4kDdUdOpfu5pd/FlEJsU1KIcdQGP3/o2dZwxK0budpnO6aAX6RfDJtMBK47G66WmURgcD9o2hnEyxEI0Mbc8Mw==","shasum":"2ddcbc8af564f68cc8c24f45eb3d2825a04571d4","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-4.6.2.tgz","fileCount":28,"unpackedSize":260785,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJbo2SQCRA9TVsSAnZWagAAd28QAIa0pSiYIBZEuJ3HIYC4\nrpdMYUyWqqLukcDF7geB5OwzEDRLHEZ6hsalsZpxkgtsvyMg2PLc3w6o0g3+\nhQRJHSA+ju9Badmv9hBpqVLvESpULToqspSqfL0s9x/g02cRa92eN7xQRFTG\nfzSmMP4TDmDVnICQIOBdGylKVD1O4LOG3Poo5QXOdtEprIZ4UrqzWWHla1W9\nlHVqmiJ3ykod727MU2glq5WJEJSRKBqt4dughqs8Nz5p+3+02jPPhkIuP4CU\nfRXJuL+aicnomT3U1b7QGKvj2SbQEEEsj9DsZ0YhQ0QILlpKmxCDuF/G7nRl\n2UJALjRVCSIIqVpfSrDk/nApmMFEzjgJvYEEvQzSIwosujdz8MI1lmK4pgYl\nvwwlQA3eCMwuaVo6QFFMevYK4A7OTfU1P7UKFifCoWPx3XhDMzeOgJdoA2IY\nAVFSSltD4b4Wj3btGftCdIdla2DdavqmW8Ax40HoG2vrDYh4XicXe/Gbyw3q\nYzvAHHkaLbKeitwpGIeRTz2JpaF1SZb1+5OyPKB8fehSKzGl/jpWz5m9ghbI\nOrxb/5PmTccp/JN7an3UlUqxtD/bDYBApBbvqFJ51D0jmmiUADkAnFuHZBio\nB3eb9/Rr+fM5TwZy6VrkTWuMlGY0WrmCM82jwbmby0S+xuFrMeE9ex0wGucp\n0SG7\r\n=jUAY\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIHBvtae8+JSB6/rCkfK1LyfqFQOv6MmesehG3Srr+E14AiApD9lsl5ttnyg5/6khBNI9FDxD/8DH6rZyeVP+JKrHYQ=="}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-streams_4.6.2_1537434768208_0.8347211833875472"},"_hasShrinkwrap":false},"4.6.3":{"name":"kafka-streams","version":"4.6.3","description":"kafka-streams for Node.js","typings":"index.d.ts","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"_mocha test/unit/Observable.test.js","test-unit":"_mocha --recursive --exit -R spec test/unit","test-int":"_mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:debug":"DEBUG=sinek:*,kafka-streams:* _mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:cov":"istanbul cover _mocha -- --recursive --timeout 22500 --exit -R spec test/int/ && istanbul check-coverage --statements 60","test":"npm run test-unit && npm run test-int","jsdoc":"rm -r ./docs/jsdoc && jsdoc ./lib --recurse -R ./README.md -d ./docs/jsdoc","jsdoc2md":"rm ./docs/doc.md && jsdoc2md -f ./lib/**/*.js -d > ./docs/doc.md","docs":"npm run jsdoc && npm run jsdoc2md","kafka:start":"./kafka-setup/start.sh","kafka:stop":"./kafka-setup/stop.sh","kafka:logs":"docker-compose --file ./kafka-setup/docker-compose.yml logs -f","ts":"tsc ./index.d.ts"},"repository":{"type":"git","url":"git+https://github.com/nodefluent/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/nodefluent/kafka-streams/issues"},"homepage":"https://github.com/nodefluent/kafka-streams#readme","dependencies":{"bluebird":"~3.5.2","debug":"~4.0.1","global":"^4.3.2","most":"~1.7.3","most-subject":"~6.0.0","npm-check-updates":"^2.14.2","sinek":"~6.22.2"},"devDependencies":{"async":"~2.6.1","jsdoc":"~3.5.5","jsdoc-to-markdown":"~4.0.1","log4bro":"~3.7.1","mocha":"~5.2.0","proxyquire":"~2.1.0","uuid":"~3.3.2"},"gitHead":"eefb9d3077abf79aec46e8bf05c4f8cdf88f767e","_id":"kafka-streams@4.6.3","_npmVersion":"6.1.0","_nodeVersion":"10.7.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"integrity":"sha512-r6iycUAIe0WRjD89Y59K7lvxzSCc5nGYY4tMfdlxLDJjDfJ0FAMuQQhfsBuK74/wGvjLjCxajfQw1lr/HSYMzg==","shasum":"feb38d713555a76ea6be1a9f16e8868d6b33124b","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-4.6.3.tgz","fileCount":28,"unpackedSize":260888,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJbo2axCRA9TVsSAnZWagAAzNQQAIGlbiLUZYrL2FhfIrnD\n+JePTPllPxLU6fn3h9BT5AclxyuG395Gxc6N5bQS3dyqi1vyymlFDvGTj1bn\nqobYUMO2u8sl+BzEP5rd8RMNzeFt3aCDS1nPgcxJvJxvw9ltOF4z7nXwEa4w\nHpWEPMbRxHvNfqaULVah8yWnqzfALrgGNAakO1q6afbjJlSZOb3saJduHMJ7\nbI7FrW7YoIN0NGTvSDB2WhmEadLpYvsqVSoo6st/zG15jeWzrVA0qh+z935E\nwTvOLju5zelS8vmBdha+hwls+NsgVy5kyryYnTgq32RyJh5eDem+OQrBLaee\ntgLnZzkgDEwvdy2bDAlO5V3mQoqty7SE9NIz6POmZauHv4JfkPN2BmgxzA9i\n87guvHa1eoGxWmmelLV6XSsAah/GwwMOwAoCr26hffgKhx6OQUw9EOeuVkjJ\nAPrguGOj0atm2C8HSuPhhHBBNtQN03Llh/CQEFMo5DdBUY/OIn1gggsaOroK\n3S/sdRZhFkASaDUiO/R3PkT3rwoXyDwPov5RW0TsJumNSAUuLhVxUUUvNI1J\n3U7lkD3tNzzusJTlNUzHsaluWSTS37Nfe2us6XMLtyhC4O988TT2qmHz9zz/\nwCuiws5VCFu62Z8ZE7Kg26dPfRvpRBV34pRc1/Y7GNiOzaITKVLhSyyABgjC\n1hrP\r\n=nZIp\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQCwJylNK3T3LFbZK5Xx/5uFjTMj0FTZgvXS/4O/7VRpuQIgB/N9zcu/0/8tr+eLGDtZ0Fauz70JMq+qoVj65aeSkH8="}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-streams_4.6.3_1537435313102_0.9802807476008188"},"_hasShrinkwrap":false},"4.6.4":{"name":"kafka-streams","version":"4.6.4","description":"kafka-streams for Node.js","typings":"index.d.ts","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"_mocha test/unit/Observable.test.js","test-unit":"_mocha --recursive --exit -R spec test/unit","test-int":"_mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:debug":"DEBUG=sinek:*,kafka-streams:* _mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:cov":"istanbul cover _mocha -- --recursive --timeout 22500 --exit -R spec test/int/ && istanbul check-coverage --statements 60","test":"npm run test-unit && npm run test-int","jsdoc":"rm -r ./docs/jsdoc && jsdoc ./lib --recurse -R ./README.md -d ./docs/jsdoc","jsdoc2md":"rm ./docs/doc.md && jsdoc2md -f ./lib/**/*.js -d > ./docs/doc.md","docs":"npm run jsdoc && npm run jsdoc2md","kafka:start":"./kafka-setup/start.sh","kafka:stop":"./kafka-setup/stop.sh","kafka:logs":"docker-compose --file ./kafka-setup/docker-compose.yml logs -f","ts":"tsc ./index.d.ts"},"repository":{"type":"git","url":"git+https://github.com/nodefluent/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/nodefluent/kafka-streams/issues"},"homepage":"https://github.com/nodefluent/kafka-streams#readme","dependencies":{"bluebird":"~3.5.2","debug":"~4.0.1","global":"^4.3.2","most":"~1.7.3","most-subject":"~6.0.0","sinek":"~6.22.3"},"devDependencies":{"async":"~2.6.1","jsdoc":"~3.5.5","jsdoc-to-markdown":"~4.0.1","log4bro":"~3.7.1","mocha":"~5.2.0","proxyquire":"~2.1.0","uuid":"~3.3.2"},"gitHead":"1a54206db455b862f478cfa877b292cc1f361a79","_id":"kafka-streams@4.6.4","_npmVersion":"6.4.1","_nodeVersion":"10.11.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"integrity":"sha512-Lf3MmlbkmgfGYVLY++7T742ybjcaxYRTuuUp5ONa2W7dLSdcGogD3l7NKFRVljiiWCL4h5QG0XpbDtwXoJVFug==","shasum":"47a64d6adc7fb8302d35d8058fb130683be75fba","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-4.6.4.tgz","fileCount":28,"unpackedSize":252332,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJbu4iKCRA9TVsSAnZWagAAdb4P/Rq+TwTzOKX9IudIc8n7\nFgIJlruY3aa8GryVyUBhpc1LZgmwAvEscedoNCMRoqiR5G1IWH4DmFY3ZpZm\n6sQk4rFAAL1vDeocO9Xq1qNDrTgllFnVgWqeQ0LSZvaXK14FIAPGwdetK1xe\nU0rQjQg7t4rIJEzODJhg5MHUzogSvZmrbj/3UtSpzepXx7ECPUFdhH7DFiEo\nm2J5bFVLAfDrMSrai20yn+w7Sc8mSndRITj1OJINrnTpEbK+0+u8R8pMzZ+v\naCJyQUHMJ5fQ5KEIr+s95MO29AFwTTm8CvJTlXjZIbN9eWdSQKasDwSkoMNQ\nFa3w5sy6nIhDEUru71aAF7tylABwexCsmFU7KzBx15eO4i48/4Bsc5P6Yd2L\nDTB7Yp0Mk19m//egpGveGwVe7UrA3ji+mcfAv6ErouF6q7GFyBHPxEeosz+O\nlCJtkAmy7rFNskuzNqdclyaU/QLvE8bh4VMn8tyc1N1Y6GOtRwY1L3hooApe\nJmbM43cW8+w7wHPMSSpjVF7eRqxrye33MZuqJHx3Bfd5KQmQiew8JUdYf5pA\nQPgnejr82NZ4/4DRuk2ivwy4uWI4cbECxgc6LNnJ6wFGwqEwTTFcazwEesbh\nQYOVOxz9cMpWXZNr7t4GKwlD7b4MNIpp5PgejgELI5+2XG1dHYD1uAxJUHun\nsnzi\r\n=9iy7\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCICvse4Alwmp/DQPU8VpPiHlyeqTtr1wUH6LXTX3N3LG+AiAT06bn54DdDOGCQdYyDV4N3X9LvL0iUIZ2U8mwCwMB2Q=="}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-streams_4.6.4_1539016841121_0.27540592098412753"},"_hasShrinkwrap":false},"4.6.5":{"name":"kafka-streams","version":"4.6.5","description":"kafka-streams for Node.js","typings":"index.d.ts","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"_mocha test/unit/Observable.test.js","test-unit":"_mocha --recursive --exit -R spec test/unit","test-int":"_mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:debug":"DEBUG=sinek:*,kafka-streams:* _mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:cov":"istanbul cover _mocha -- --recursive --timeout 22500 --exit -R spec test/int/ && istanbul check-coverage --statements 60","test":"npm run test-unit && npm run test-int","jsdoc":"rm -r ./docs/jsdoc && jsdoc ./lib --recurse -R ./README.md -d ./docs/jsdoc","jsdoc2md":"rm ./docs/doc.md && jsdoc2md -f ./lib/**/*.js -d > ./docs/doc.md","docs":"npm run jsdoc && npm run jsdoc2md","kafka:start":"./kafka-setup/start.sh","kafka:stop":"./kafka-setup/stop.sh","kafka:logs":"docker-compose --file ./kafka-setup/docker-compose.yml logs -f","ts":"tsc ./index.d.ts"},"repository":{"type":"git","url":"git+https://github.com/nodefluent/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/nodefluent/kafka-streams/issues"},"homepage":"https://github.com/nodefluent/kafka-streams#readme","dependencies":{"bluebird":"~3.5.2","debug":"~4.0.1","global":"^4.3.2","most":"~1.7.3","most-subject":"~6.0.0","sinek":"~6.22.3"},"devDependencies":{"async":"~2.6.1","jsdoc":"~3.5.5","jsdoc-to-markdown":"~4.0.1","log4bro":"~3.7.1","mocha":"~5.2.0","proxyquire":"~2.1.0","uuid":"~3.3.2"},"gitHead":"b6d30d4619f64a08467996fb3acf90c06ceb0c0d","_id":"kafka-streams@4.6.5","_npmVersion":"6.4.1","_nodeVersion":"10.11.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"integrity":"sha512-RzShR4wqFvgXsGEMsk3xmsKJxi1zonZukhz7XuAhjyOrnjSc5l+dp/hnCuUU3yC6FryFtIcxK+fZtgY5TU4juQ==","shasum":"2caff770442477628bd321ece028ed08e03aae94","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-4.6.5.tgz","fileCount":28,"unpackedSize":252424,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJbvJEyCRA9TVsSAnZWagAAD44P/jrcIniZTJ8U1j59GQtm\nqncjcVx2zvXD0fF4HuOCO5P1NTR16xt1N6IXhARyeNfC52Jvc5UCdO3Z1obX\n+NyMeTd82WwqWej6u1fI4fXCCwC3ALzH8pnCycgVr00/70s1gRkkqNfok55t\nk+1Aa0JV+5TCrLxAwJ5di/OJ7XVlMjPf4GPLIehHJmi4s+BBoQQ1AqYEoU7I\nN6aIKwbXud5/lmUjhh1mw1RZy+5BSz51MMwYx/GTltiCd/uThE7tQcvFfN21\n3yyUevgRcimj+Pc+yec1I4+sP32eUMZ7oQ2506Vhgw6EKZu1pZH84+eEp/7M\nv71gmFyN98EfTpUZuhTJcovxO9rNY4pjfQRWNUYJ9z40GzFsc7tRJ9Mozpqi\nweskltl+PrQzppEz7ryRXA7ZBSulBt8NX3Y47zFdHt3tZeh5ytWGTcBqRAA5\nPI8uP3MKXO3ueQjcByLeA9MPO7Z120GgWLeLCZxzSW+IHUh1ldok70NVha7i\nhIlwbFZpPRt2oDLafNhsbPmpzdSUVj8iF0K3/8Cj1K/zdlw62UbFtGdcoP70\nT2v6o2Ljpr5ESW8aZ8vI9VRl1vqZwndUcLmPOC6rHNYm+WywPKze37K8bkXL\ne8qBJAwpTtd+8kyujaq2ASvLVcVA2QqoQxeyCZKwmy3KBvDH2nKG91g/uvdk\nYENs\r\n=Vnu5\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIEoRQHLLqkQDjtf7aHJYsXB/VMxrzi4gTbKNk0Hmg7JaAiArn8yqiLoHcw5G/kcA/v3g5Hdkv7XwEpC4SRDh8RuYEg=="}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-streams_4.6.5_1539084593387_0.10948644150256714"},"_hasShrinkwrap":false},"4.7.0":{"name":"kafka-streams","version":"4.7.0","description":"kafka-streams for Node.js","typings":"index.d.ts","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"_mocha test/unit/Observable.test.js","test-unit":"_mocha --recursive --exit -R spec test/unit","test-int":"_mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:debug":"DEBUG=sinek:*,kafka-streams:* _mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:cov":"istanbul cover _mocha -- --recursive --timeout 22500 --exit -R spec test/int/ && istanbul check-coverage --statements 60","test":"npm run test-unit && npm run test-int","jsdoc":"rm -r ./docs/jsdoc && jsdoc ./lib --recurse -R ./README.md -d ./docs/jsdoc","jsdoc2md":"rm ./docs/doc.md && jsdoc2md -f ./lib/**/*.js -d > ./docs/doc.md","docs":"npm run jsdoc && npm run jsdoc2md","kafka:start":"./kafka-setup/start.sh","kafka:stop":"./kafka-setup/stop.sh","kafka:logs":"docker-compose --file ./kafka-setup/docker-compose.yml logs -f","ts":"tsc ./index.d.ts","yarn:openssl":"LDFLAGS='-L/usr/local/opt/openssl/lib' CPPFLAGS='-I/usr/local/opt/openssl/include' yarn"},"repository":{"type":"git","url":"git+https://github.com/nodefluent/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/nodefluent/kafka-streams/issues"},"homepage":"https://github.com/nodefluent/kafka-streams#readme","dependencies":{"bluebird":"~3.5.2","debug":"~4.1.0","global":"^4.3.2","most":"~1.7.3","most-subject":"~6.0.0","sinek":"~6.23.3"},"devDependencies":{"async":"~2.6.1","jsdoc":"~3.5.5","jsdoc-to-markdown":"~4.0.1","log4bro":"~3.7.1","mocha":"~5.2.0","proxyquire":"~2.1.0","uuid":"~3.3.2"},"gitHead":"262d971eb342f990300470cf2b2ef93010c50be8","_id":"kafka-streams@4.7.0","_npmVersion":"6.4.1","_nodeVersion":"10.11.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"integrity":"sha512-g3W00jhH0VzR34CLxDmId8BBeQgQf2FCxVsn8X/Es3PkKTWkYGZPRHnaiYT2osBYF66dXWG/Uq/moy2e948YgQ==","shasum":"43a0b8bb2411a08e131682c54febd69804af17c3","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-4.7.0.tgz","fileCount":26,"unpackedSize":256418,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJbxfcrCRA9TVsSAnZWagAAnSoP/293urZOCD/xN1hR5Rj0\nCZoosyRbGZ5QfDIzqfWRWgkz8XEPP1NAO26KQw5YIQfeacO1GPl3CcrQmzEE\n9P+azdHfuSwRN1Y0BTAuIY09hsLya6Pc1bt8Y81+TIaJbNgKcA4/aGNIVpgI\nk5bq+uh3Qq7SbF/WuzA8tFS1Ek7eAYJkk+0n5dcfPyVvMjSq+6EPWHyD9Ccc\nXykx+W6JqHyWuxLur8e9dXOmr4wsexjIYG2UUp1soxjLIOvDQWayqmfeGfVg\nBPnnlMRMpcJXXFvX3SqHycbE1zAIUI6WSfEpi46uyKNIMM2WzrsEV8EyIV0K\njCFmJ71ChPSPqay7UwUk+j63m+gI6Wkv1ENI+A6SNXLS0VIv/77uId73GKp4\nEgX4laUEx8oYUlzTGJdoC2SAufBthoBnNiIzk0lRG4c33xuFQrAW/lgxjPvh\nqGgtVJpEnK/7rQKXMcUa9s0lRZ4xBFleRn4YQIQpzHhwzWN7ilYO732LkVSG\nc+z1of9hNNK5TrB3afnlbZ9zl8iVe+bTnIjuvdakQSdmD8bUdWO8nKAzRdCq\nLQTVUVnXt9oxgA5N73QZBaWq1812JWbxgUuQhzbjsTeaCfKwBkEOIkqR/VNk\n+o6Q9wxlqhP1ngNH/jpyIRxG+aC/+ZiSnYjxrq6ozBnv2vDxXrZH2hLbdtXr\neKqN\r\n=wdXo\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCgIbvWudoM+0fayDK2iuXvD/Ugc3x3t4jRiy+7XGnpGgIhAOVQ9PvsSx8fQ/2ls+6TNoddkcSKE9UdEpx68P0kbude"}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-streams_4.7.0_1539700522968_0.644189771581442"},"_hasShrinkwrap":false},"4.8.0":{"name":"kafka-streams","version":"4.8.0","description":"kafka-streams for Node.js","typings":"index.d.ts","main":"index.js","scripts":{"word-count":"node ./examples/wordCount.js","obs-test":"_mocha test/unit/Observable.test.js","test-unit":"_mocha --recursive --exit -R spec test/unit","test-int":"_mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:debug":"DEBUG=sinek:*,kafka-streams:* _mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:cov":"istanbul cover _mocha -- --recursive --timeout 22500 --exit -R spec test/int/ && istanbul check-coverage --statements 60","test":"npm run test-unit && npm run test-int","jsdoc":"rm -r ./docs/jsdoc && jsdoc ./lib --recurse -R ./README.md -d ./docs/jsdoc","jsdoc2md":"rm ./docs/doc.md && jsdoc2md -f ./lib/**/*.js -d > ./docs/doc.md","docs":"npm run jsdoc && npm run jsdoc2md","kafka:start":"./kafka-setup/start.sh","kafka:stop":"./kafka-setup/stop.sh","kafka:logs":"docker-compose --file ./kafka-setup/docker-compose.yml logs -f","ts":"tsc ./index.d.ts","yarn:openssl":"LDFLAGS='-L/usr/local/opt/openssl/lib' CPPFLAGS='-I/usr/local/opt/openssl/include' yarn"},"repository":{"type":"git","url":"git+https://github.com/nodefluent/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/nodefluent/kafka-streams/issues"},"homepage":"https://github.com/nodefluent/kafka-streams#readme","dependencies":{"bluebird":"~3.5.3","debug":"~4.1.1","global":"^4.3.2","most":"~1.7.3","most-subject":"~6.0.0","sinek":"~6.24.0"},"devDependencies":{"async":"~2.6.1","jsdoc":"~3.5.5","jsdoc-to-markdown":"~4.0.1","log4bro":"~3.7.1","mocha":"~5.2.0","proxyquire":"~2.1.0","uuid":"~3.3.2"},"gitHead":"57d3e7a3ca0a0f9b534fe08e99bb7b41e2705ec7","_id":"kafka-streams@4.8.0","_npmVersion":"6.5.0","_nodeVersion":"11.6.0","_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"dist":{"integrity":"sha512-Bx6LCRqHrlTu6fWX8TitUZPQC5VmocAy8AwNGB+YDZnR4MabiYwRW+xhPkrUp3zwp2u2SQ6TejU76omgKTNHsQ==","shasum":"717632c5c49f014a825733e26c91ef739de086b4","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-4.8.0.tgz","fileCount":26,"unpackedSize":258203,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJcNiUrCRA9TVsSAnZWagAA8sMQAJOp7mOe0Yya8xgXfqs4\nrlz0905WCWT/X8kKhqLCILnrqUzoUtA4bVltvnIxc8EF78NmSG4axtZlAIr+\n9aegP+IZZnh8GnEgi15kd/ZBrBMGxfZfnrC5JTkgf6+akebfQA5alcS7Raxt\nGw/6/d9xCjxI/aKqNcZbpzk4Jlq7UU3d9KAxXZHxskXvtkARScBT+nWF6LUd\nO7ymojCuvgR8gXnubtKxVPpBTGTZQOTzHPR7SB+kMFNY7gFtRaBH7mJw1Uai\n9z4X/TQqGnIjVfLL2ireenF2sViEu7rxo6YEjCdswu01vGXZJRuw0CoXvkiM\niOK5mkNn8kF1N5DbOIIAN6fKYgTUdubbtIkjMC5JcqYC7TqBq8Bgs3pu8CtJ\nOhl5yticeBBsrIJrpbtjnAw4Kk38kQOIq9x0lJgX+sXCThQ/YY2X+dcVxqXV\naaTvvNfAdhjLyJB//R0FyNUwqVYhXsrvI/KubixI8yUyT5RtJRlT3H0XswKR\nma/FmJWUDZZj9fEhbTpqR4ZRK7hJlUx98vkVW8x4yEb6NikcvpSiSLTY0xQ5\nqt5TgQFMd+MrQk+ZNE8ULkF2SCbBEST5AoO97HadOOq+hBZq+wEgob9ZZRsu\ni+qVMKzngtXsu6mwfwemqYvGjXID1OLz/GW8OKBi2EAg5I6B2QZhIfGe77TC\nYK/F\r\n=Nzci\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIHnCYOBRdOGEDwbX6iwWEHqFo9SRkZLfbsdH1k+BMahIAiBoRfBrpPz/hhPXesvtQRDjX0KMGUD/OGWpl6Pji1tLkg=="}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-streams_4.8.0_1547052330579_0.5346911268391268"},"_hasShrinkwrap":false},"4.9.0":{"name":"kafka-streams","version":"4.9.0","description":"kafka-streams for Node.js","typings":"index.d.ts","main":"index.js","scripts":{"consumeFromTopic":"node ./examples/consumeFromTopic.js","consumeOneProduceTwo":"node ./examples/consumeOneProduceTwo.js","fieldSum":"node ./examples/fieldSum.js","mergeTopics":"node ./examples/mergeTopics.js","produceToTopic":"node ./examples/produceToTopic.js","topicAsTable":"node ./examples/topicAsTable.js","window":"node ./examples/window.js","wordCount":"node ./examples/wordCount.js","word-count":"yarn wordCount","obs-test":"_mocha test/unit/Observable.test.js","test-unit":"_mocha --recursive --exit -R spec test/unit","test-int":"_mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:debug":"DEBUG=sinek:*,kafka-streams:* _mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:cov":"istanbul cover _mocha -- --recursive --timeout 22500 --exit -R spec test/int/ && istanbul check-coverage --statements 60","test":"npm run test-unit && npm run test-int","jsdoc":"rm -r ./docs/jsdoc && jsdoc ./lib --recurse -R ./README.md -d ./docs/jsdoc","jsdoc2md":"rm ./docs/doc.md && jsdoc2md -f ./lib/**/*.js -d > ./docs/doc.md","docs":"npm run jsdoc && npm run jsdoc2md","kafka:start":"./kafka-setup/start.sh","kafka:stop":"./kafka-setup/stop.sh","kafka:logs":"docker-compose --file ./kafka-setup/docker-compose.yml logs -f","ts":"tsc ./index.d.ts","yarn:openssl":"LDFLAGS='-L/usr/local/opt/openssl/lib' CPPFLAGS='-I/usr/local/opt/openssl/include' yarn"},"repository":{"type":"git","url":"git+https://github.com/nodefluent/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/nodefluent/kafka-streams/issues"},"homepage":"https://github.com/nodefluent/kafka-streams#readme","dependencies":{"bluebird":"~3.5.4","debug":"~4.1.1","global":"^4.3.2","most":"~1.7.3","most-subject":"~5.3.0","sinek":"~7.29.3"},"devDependencies":{"async":"~2.6.2","jsdoc":"~3.6.1","jsdoc-to-markdown":"~4.0.1","log4bro":"~3.9.0","mocha":"~6.1.4","proxyquire":"~2.1.0","uuid":"~3.3.2"},"gitHead":"7310c4104331cfcad2083bc19221d380b7bacecd","_id":"kafka-streams@4.9.0","_nodeVersion":"11.15.0","_npmVersion":"6.7.0","dist":{"integrity":"sha512-FaZEanlTjszfXwtgwqy57FoUiTe2sgFKbzF+5P++1Qzw0WyYJ67LXYFkFYnrBQeMLgI+/67dKEzE6WNT242Ucg==","shasum":"f5244b3f138ae891cf1bfc08e0bed1f9f5d34564","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-4.9.0.tgz","fileCount":26,"unpackedSize":237280,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJc0c+1CRA9TVsSAnZWagAACGQQAIGnKQb/n/dgdP3FJ8SZ\nn+HTozfBBsiVy9UyjPGWr3Gxaoky0ZPN9npQv+kWJiYxOzjim6pyb+byK9Kq\n7GNIp8A47AmVnUAXlQwX5HgrYTKemvQkS24ykbQNID77lrl3+8/FRtzIqchF\n1R0Cljp9rCj+GVM88Zqani0g85GU8B/HPfxSvZe9QPDXUVScdcTKuDgeN7WK\ntd7h2aL7R6sdy8Z032Q3Gd41QwA2L+qjwrTE+zzWIko1Cnb+7RzmS0eUUaPV\nhuxbmbRH/kiD8rl3sIf0Ms00B+iSD1TkVJPUwGIbfcM98XvKuOZcwrVt6uP1\nhdIYrqpak5/PC92rVR2CblzHIP4xrvaqG/X5p4zkwW8fFPRDBD1qP5mg/4v7\nIwBB2KHbUSC4oSRCLHb4LtrS45Kzr3Of2Pa+C28Lg65nOXGgrhUPrDUzFg9k\n5B0gAMT9W1cX6BBB7XDJvcwierb92FgsQs4diCPGQpRqcVCGOroRDAOxn34F\nZ3NNOdRDbMGjbW3HhoVyho+2ehy7j1xhqlqovcOPy5eCnAxlCmmwOMute5+W\nFirtRAu5KWaZKWI94bwiFtmJ1IP0o/b7XVNwXjkzJEYY+VXn53wEotL0IbXH\nF9lG+lF8AEvJe0TvAayBXTYBCUbPlJDqFk9CdK/d1oZT1iKaWRaJZLovZPgx\nnkAs\r\n=jy6q\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQC+bXZwh0i4fSJFFR9XE2ma3PSvGv3/q3X3jll/A95uwgIhALMKOqchZiptjdd/isRVduXTLqCOrfQvCaw9UeSa82ik"}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-streams_4.9.0_1557254068335_0.6449602062904471"},"_hasShrinkwrap":false},"4.10.0":{"name":"kafka-streams","version":"4.10.0","description":"kafka-streams for Node.js","typings":"index.d.ts","main":"index.js","scripts":{"consumeFromTopic":"node ./examples/consumeFromTopic.js","consumeOneProduceTwo":"node ./examples/consumeOneProduceTwo.js","consumeOneProduceTwoTopics":"node ./examples/consumeOneProduceTwoTopics.js","fieldSum":"node ./examples/fieldSum.js","mergeTopics":"node ./examples/mergeTopics.js","produceToTopic":"node ./examples/produceToTopic.js","topicAsTable":"node ./examples/topicAsTable.js","window":"node ./examples/window.js","wordCount":"node ./examples/wordCount.js","word-count":"yarn wordCount","obs-test":"_mocha test/unit/Observable.test.js","test-unit":"_mocha --recursive --exit -R spec test/unit","test-int":"_mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:debug":"DEBUG=sinek:*,kafka-streams:* _mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:cov":"istanbul cover _mocha -- --recursive --timeout 22500 --exit -R spec test/int/ && istanbul check-coverage --statements 60","test":"npm run test-unit && npm run test-int","jsdoc":"rm -r ./docs/jsdoc && jsdoc ./lib --recurse -R ./README.md -d ./docs/jsdoc","jsdoc2md":"rm ./docs/doc.md && jsdoc2md -f ./lib/**/*.js -d > ./docs/doc.md","docs":"npm run jsdoc && npm run jsdoc2md","kafka:start":"./kafka-setup/start.sh","kafka:stop":"./kafka-setup/stop.sh","kafka:logs":"docker-compose --file ./kafka-setup/docker-compose.yml logs -f","ts":"tsc ./index.d.ts","yarn:openssl":"LDFLAGS='-L/usr/local/opt/openssl/lib' CPPFLAGS='-I/usr/local/opt/openssl/include' yarn"},"repository":{"type":"git","url":"git+https://github.com/nodefluent/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/nodefluent/kafka-streams/issues"},"homepage":"https://github.com/nodefluent/kafka-streams#readme","dependencies":{"bluebird":"~3.5.4","debug":"~4.1.1","global":"^4.3.2","lodash.clone":"^4.5.0","lodash.clonedeep":"^4.5.0","most":"~1.7.3","most-subject":"~5.3.0","sinek":"~7.29.3"},"devDependencies":{"async":"~2.6.2","jsdoc":"~3.6.1","jsdoc-to-markdown":"~4.0.1","log4bro":"~3.9.0","mocha":"~6.1.4","proxyquire":"~2.1.0","uuid":"~3.3.2"},"gitHead":"eb04187fec3a5297a38269c3dc1405a325a26339","_id":"kafka-streams@4.10.0","_nodeVersion":"11.15.0","_npmVersion":"6.7.0","dist":{"integrity":"sha512-zDOVL7JxiAEYQIrIPqCHGRlgHeTlM/3+snJWLsD0Ykzx+qnNvITCFCD24W1uOWOa0Z9lim1nP4YUWWZ2EZOIEw==","shasum":"4949aff2c2e25233776b14618623b0f99b9532bc","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-4.10.0.tgz","fileCount":26,"unpackedSize":239666,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJc2R/sCRA9TVsSAnZWagAAkF0QAKD2up+a759jugVWqSjJ\nnKk6WDR+esWtiu2aFFqVu+Xwqc9AETnHoad0ftLM4HuMPemeKbVcSO4hlKbV\n8p5PSq39xl5KkgaYPYbzKtuVgSdC3KtUmqKyyoDwELwhDlyd7/TazSPaj1H+\nsdrIsKa13iVKG0mgtxTEK3uPKFrRSRiBFP6ocipTwwvDyuf/Bic5vLNBozhP\ney4Sxn/A9WY6ZJFiSGH7nCE/jtRRUcBwkyku8ViCm2K37LKQ35jcnI1UNP0R\n0xpShP5nISRxKLe6y+yM7ygJLi5tumWqXPSFQiKKMrdE0YtKyksBLFOYPyme\nYAyaCaj486roZkc5TlNxoaNqBWVmJ97x+ZPKfDzC9TArPGtTXCG4YwQG3dvM\nzJbCd2lyQZYKWwlKhp1dmES77hLFRf3dhaoqiq+n/q3i7NGoYMH/OTwWlBkR\ns4Z9xIi42T8xSGoijCFUNBEDFLNKcBvPfhKxKR9QuUiWijPHqPa2KCcvh5nW\nel7voClAlazkHWG3I8mEyxROj3c+gPC4GPQXsWNpLL/PHwc9zIdQca6Tis/P\nkAVUjZYVdXcOEyiILVf9WWPSuOiNONK9194RXzu6hbFX1CXDLqWQuGIwHlcy\newz2KNeb3wImaCbOsFtl/hOFtVho0fnyE70CRkvBFrtSfAfSszsZ3gHszggi\nd55A\r\n=2xYe\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIHxm4jEZ/+ThKul9QQ/nWVUHPBnJKgLtiHrQnzQapRPWAiANzcfEW/euCcjwxjoPwIHsP2oq7Br/FazWT7nlbA1C+Q=="}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-streams_4.10.0_1557733355350_0.9873383701919751"},"_hasShrinkwrap":false},"4.11.0":{"name":"kafka-streams","version":"4.11.0","description":"kafka-streams for Node.js","typings":"index.d.ts","main":"index.js","scripts":{"consumeFromTopic":"node ./examples/consumeFromTopic.js","consumeOneProduceTwo":"node ./examples/consumeOneProduceTwo.js","consumeOneProduceTwoTopics":"node ./examples/consumeOneProduceTwoTopics.js","fieldSum":"node ./examples/fieldSum.js","mergeTopics":"node ./examples/mergeTopics.js","produceToTopic":"node ./examples/produceToTopic.js","topicAsTable":"node ./examples/topicAsTable.js","window":"node ./examples/window.js","wordCount":"node ./examples/wordCount.js","word-count":"yarn wordCount","obs-test":"_mocha test/unit/Observable.test.js","test-unit":"_mocha --recursive --exit -R spec test/unit","test-int":"_mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:debug":"DEBUG=sinek:*,kafka-streams:* _mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:cov":"istanbul cover _mocha -- --recursive --timeout 22500 --exit -R spec test/int/ && istanbul check-coverage --statements 60","test":"npm run test-unit && npm run test-int","jsdoc":"rm -r ./docs/jsdoc && jsdoc ./lib --recurse -R ./README.md -d ./docs/jsdoc","jsdoc2md":"rm ./docs/doc.md && jsdoc2md -f ./lib/**/*.js -d > ./docs/doc.md","docs":"npm run jsdoc && npm run jsdoc2md","kafka:start":"./kafka-setup/start.sh","kafka:stop":"./kafka-setup/stop.sh","kafka:logs":"docker-compose --file ./kafka-setup/docker-compose.yml logs -f","ts":"tsc ./index.d.ts","yarn:openssl":"LDFLAGS='-L/usr/local/opt/openssl/lib' CPPFLAGS='-I/usr/local/opt/openssl/include' yarn"},"repository":{"type":"git","url":"git+https://github.com/nodefluent/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/nodefluent/kafka-streams/issues"},"homepage":"https://github.com/nodefluent/kafka-streams#readme","dependencies":{"bluebird":"~3.5.4","debug":"~4.1.1","global":"^4.3.2","lodash.clone":"^4.5.0","lodash.clonedeep":"^4.5.0","most":"~1.7.3","most-subject":"~5.3.0","sinek":"~7.29.3"},"devDependencies":{"async":"~2.6.2","jsdoc":"~3.6.1","jsdoc-to-markdown":"~4.0.1","log4bro":"~3.9.0","mocha":"~6.1.4","proxyquire":"~2.1.0","uuid":"~3.3.2"},"gitHead":"89f522f2178aa154a937ea74988ba2f454f4dbe6","_id":"kafka-streams@4.11.0","_nodeVersion":"11.15.0","_npmVersion":"6.7.0","dist":{"integrity":"sha512-Nfb5uy0ESck1lXvWdr8rx0pOMbf0cijGqGBu2EZxyK2me+pE4M2O4SamBJjuK1eSJHGuS600Pfb1zSqRoQMjMQ==","shasum":"0b3aa9fa332cdb89b0cc4f26101bcef9dd3e9af8","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-4.11.0.tgz","fileCount":26,"unpackedSize":240068,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJc3eSfCRA9TVsSAnZWagAAkvMQAJGRIQVQYuhl0KmNvWiD\n0jn/xISyjZGwVIBXMmb5EBRiO4SPqyG/cEsaW0J5kZ9spkTkOtxULb08+7yZ\nXaR66DZ7vp13yg0rA1wUFdkb5P+95kdP/zlo0yGPudzksZo2Lnhrztili2t9\nsJpu11J/Jb8DJoy+SNzT5KQuVEnFtQJSqrY0RLC3KrZ+FgqL7R8l0f4vz5nJ\nY2t5hziHflz0nCOrXW0qrPtItFTlYrvk5/n1wsKWUivGdRwAh+gJ/0edQjho\nUm1iFRAhEIHKfmWcYCdvPDA68KKQB7YUEp4Mtvgus9WgBJidpyreFidCY5e0\neZ+5TCDV2PFtsHJsrrVmdW+mfHup5aBb5P09L7GuYKCamqyA9g5givUbWBWQ\nlGxoylqE+qUslQOblZvo6s72kon/s2yQjm4dIGUh7KkC+fcq9RSKVBMdMF3h\nGrY9siHgNMlqWSoY2OQyq374VYW1Lt2lJ6t/uC/CSjoctHy0fPp3WYEtVSqd\nNyt7n0kixRgfxCV6oNvfVvavqy8Wn2obOI+OM1ImnoefzG0MzXSp8OSPMfmN\n4NFfbvUHbOfmc+PZ5InNpsnCa7j+7zNeKKixmAsWFCzTvp1gvfzFBx6p1qeK\nyvGbiDiGkW22n0wWB19Yc7JjL57RJTcMR3PNu54ffe9vMHAh3L2/N/wHqNgE\nrtBw\r\n=m9BU\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIC2X/7tZA5VDlWUwLbIhhI7bMtRjfaV/Z0Dp3YRtvJ+ZAiEAuSJvgsq40aRnw4HXRcXuyZN7wNca1upOLJRJn5UwTuU="}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-streams_4.11.0_1558045854279_0.5041574388800458"},"_hasShrinkwrap":false},"4.12.0":{"name":"kafka-streams","version":"4.12.0","description":"kafka-streams for Node.js","typings":"index.d.ts","main":"index.js","scripts":{"consumeFromTopic":"node ./examples/consumeFromTopic.js","consumeOneProduceTwo":"node ./examples/consumeOneProduceTwo.js","consumeOneProduceTwoTopics":"node ./examples/consumeOneProduceTwoTopics.js","fieldSum":"node ./examples/fieldSum.js","mergeTopics":"node ./examples/mergeTopics.js","produceToTopic":"node ./examples/produceToTopic.js","topicAsTable":"node ./examples/topicAsTable.js","window":"node ./examples/window.js","wordCount":"node ./examples/wordCount.js","word-count":"yarn wordCount","topicExtractor":"DEBUG=kafka-streams:mph node ./examples/topicExtractor.js","obs-test":"_mocha test/unit/Observable.test.js","test-unit":"_mocha --recursive --exit -R spec test/unit","test-int":"_mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:debug":"DEBUG=sinek:*,kafka-streams:* _mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:cov":"istanbul cover _mocha -- --recursive --timeout 22500 --exit -R spec test/int/ && istanbul check-coverage --statements 60","test":"npm run test-unit && npm run test-int","jsdoc":"rm -r ./docs/jsdoc && jsdoc ./lib --recurse -R ./README.md -d ./docs/jsdoc","jsdoc2md":"rm ./docs/doc.md && jsdoc2md -f ./lib/**/*.js -d > ./docs/doc.md","docs":"npm run jsdoc && npm run jsdoc2md","kafka:start":"./kafka-setup/start.sh","kafka:stop":"./kafka-setup/stop.sh","kafka:logs":"docker-compose --file ./kafka-setup/docker-compose.yml logs -f","ts":"tsc ./index.d.ts","yarn:openssl":"LDFLAGS='-L/usr/local/opt/openssl/lib' CPPFLAGS='-I/usr/local/opt/openssl/include' yarn"},"repository":{"type":"git","url":"git+https://github.com/nodefluent/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/nodefluent/kafka-streams/issues"},"homepage":"https://github.com/nodefluent/kafka-streams#readme","dependencies":{"bluebird":"~3.5.5","debug":"~4.1.1","global":"~4.4.0","lodash.clone":"~4.5.0","lodash.clonedeep":"~4.5.0","most":"1.7.3","most-subject":"5.3.0","sinek":"~7.30.0"},"devDependencies":{"async":"~3.1.0","jsdoc":"~3.6.2","jsdoc-to-markdown":"~5.0.0","log4bro":"~3.10.0","mocha":"~6.1.4","proxyquire":"~2.1.0","uuid":"~3.3.2"},"gitHead":"2f0409a629e3a70465400e9e3d66beb9a40d1709","_id":"kafka-streams@4.12.0","_nodeVersion":"11.15.0","_npmVersion":"6.7.0","dist":{"integrity":"sha512-CP8QOmHQ/xzsYIWkczYt2qLrY/BMNaR9gPqUb9R8ImHrEA3dCQUJtFcxUjK4fQ+oTcM9k/SdhuFzJWCC4LY9Lw==","shasum":"d2169df9d4508e63d9ec81e666541daf4fd01bfe","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-4.12.0.tgz","fileCount":26,"unpackedSize":239736,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJdHf2aCRA9TVsSAnZWagAAyUsP/1aBUx984B9qLRsHpLCs\nyFl7C2eXvs02gQz6Bj5LUxqlQi3Gl4W17xMOFDfxXHTGxg5i0fBAknrC1brb\nT47BRmjhSXSvFZ+llbgzYknAwUMzKN7/mzobjFliY7RKMtY9XQX+bTByCx3B\nD7VmSzCOpI7pbbUkKiqEGOM61Q9yHfxggBbdjssoRGhlQmhOSqqEZ3WZQWDL\nselxbv9fD/JtgraNP2/K6DjPr9b1gdDY00stIsokjNIZBaz34g/WqLjOM3cS\nfFnBA1mdAuRlykVPy2Cg3481CaAeq1IW6zao4j6sElAiEIHGHcs8fpblXrf2\nRk5rUqAxlb6AQvylJhN0faC8q8nRLr4sN8AH9jrM+/YMmmWrWB7hxeSfZcum\n7QMCgVuzi5Ebfb6XxOrTVMbo6X+/bkZNZRAZT6R67zumRhMhLHDf3YIUXDhT\nxq8mzbvkr2lQKKKmfpNr6n5RbX6UuRqy3FLKSMNPPu1DiitIthfovJ+QchBF\nGysa7h2UZCUNElzJa6nKDnSRK+hnb/6zcdExSwULQ+q1pykWnhYRb/nfj/fB\nVOXk7VLq+QKeDVdIZ9SM13N2f/M1BaSpxpU5cGAqfu7Q5VfDQgAKwyLg2Whs\nR9C6PqoggLr8ZShe4AlBJrqJ0EAdLDAbIVd1Pj43tO9Gtl3G2DcddzhrN+m6\n3e2u\r\n=cdx/\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCXAf3+GdcR8lGH8j21onqx2mDYnOMy9gmpddadRjPICQIhAJA+QmM6hDp3yKnQ0SQQUZVMek+EcMcwmIQ5REDParkG"}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-streams_4.12.0_1562246553153_0.6825356688665574"},"_hasShrinkwrap":false},"5.0.0":{"name":"kafka-streams","version":"5.0.0","description":"kafka-streams for Node.js","typings":"index.d.ts","main":"index.js","scripts":{"consumeFromTopic":"node ./examples/consumeFromTopic.js","consumeOneProduceTwo":"node ./examples/consumeOneProduceTwo.js","consumeOneProduceTwoTopics":"node ./examples/consumeOneProduceTwoTopics.js","fieldSum":"node ./examples/fieldSum.js","mergeTopics":"node ./examples/mergeTopics.js","produceToTopic":"node ./examples/produceToTopic.js","topicAsTable":"node ./examples/topicAsTable.js","window":"node ./examples/window.js","wordCount":"node ./examples/wordCount.js","word-count":"yarn wordCount","topicExtractor":"DEBUG=kafka-streams:mph node ./examples/topicExtractor.js","obs-test":"_mocha test/unit/Observable.test.js","test-unit":"_mocha --recursive --exit -R spec test/unit","test-int":"_mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:debug":"DEBUG=sinek:*,kafka-streams:* _mocha --recursive --timeout 22500 --exit -R spec test/int","test-int:cov":"istanbul cover _mocha -- --recursive --timeout 22500 --exit -R spec test/int/ && istanbul check-coverage --statements 60","test":"npm run test-unit && npm run test-int","jsdoc":"rm -r ./docs/jsdoc && jsdoc ./lib --recurse -R ./README.md -d ./docs/jsdoc","jsdoc2md":"rm ./docs/doc.md && jsdoc2md -f ./lib/**/*.js -d > ./docs/doc.md","docs":"npm run jsdoc && npm run jsdoc2md","kafka:start":"./kafka-setup/start.sh","kafka:stop":"./kafka-setup/stop.sh","kafka:logs":"docker-compose --file ./kafka-setup/docker-compose.yml logs -f","ts":"tsc ./index.d.ts","yarn:openssl":"LDFLAGS='-L/usr/local/opt/openssl/lib' CPPFLAGS='-I/usr/local/opt/openssl/include' yarn"},"repository":{"type":"git","url":"git+https://github.com/nodefluent/kafka-streams.git"},"keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"license":"MIT","bugs":{"url":"https://github.com/nodefluent/kafka-streams/issues"},"homepage":"https://github.com/nodefluent/kafka-streams#readme","dependencies":{"bluebird":"~3.7.2","debug":"~4.1.1","global":"~4.4.0","lodash.clone":"~4.5.0","lodash.clonedeep":"~4.5.0","most":"1.7.3","most-subject":"5.3.0","sinek":"~9.0.0"},"devDependencies":{"async":"~3.2.0","jsdoc":"~3.6.3","jsdoc-to-markdown":"~5.0.3","log4bro":"~3.14.0","mocha":"~7.0.1","proxyquire":"~2.1.3","uuid":"~3.4.0"},"gitHead":"87dc65c2e11b13a023db9e4c44db8bacc5b3a943","_id":"kafka-streams@5.0.0","_nodeVersion":"12.16.1","_npmVersion":"6.13.4","dist":{"integrity":"sha512-hukMMzKHXwE9rjDdRspU7YThd6VZZ6uCdq4tCNbeXP/72jFhY4wKWYZSQ1rSN62dxKlURVgNIVueP7U+LfYkIg==","shasum":"77ec9f9369f15f0cd1e87853823c3681910a45b9","tarball":"https://registry.npmjs.org/kafka-streams/-/kafka-streams-5.0.0.tgz","fileCount":25,"unpackedSize":118003,"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v3.0.4\r\nComment: https://openpgpjs.org\r\n\r\nwsFcBAEBCAAQBQJeU6kPCRA9TVsSAnZWagAARaYP/1c9WAYFmxc1NGuv2Id3\nJz86K1YKpWXJPIu9FtWvBs3Dg2FOyj1w9fKZlmh7PzQQYjpcl5p5E7/hMc6b\nXvLAnlEgeh+ivKptpbYYoHrWycTgQ/abE5ecCTgpUsCgVeR6lPN29y/GgONJ\n/72qxUrLtGot/9ZM4LUK6F2mfnsP9RW+M9YLfGWuVDtjNz1v7ILSBqriad0j\nzOpkA9S2Z+7pCQs+e46AoHArIq75kaxmUt5OUEcTTkNnBuQiWeKcbLQ/RMxC\nFOcycjKmqKhsSRO+YGzjaEIujpEr6Aqh9NoUUb6zh+MfvGI/u0PJw8DGQykq\ntm8U6WEPInUlu1CY+hXTusE0raIbSe/F2mGHMQQVum7HWr8oWwy/eEnQ+MpZ\nHTH6z6oqGoL3zNi768cUCpRCrRVD71AktD6wIHuCggveJRNCt0FDfo8qrsIc\nb+mUWlSrF2Q5A7t8jFobrbu06rRjbnFC+Uxg203CY4eL0XteueklzyPifOsI\n9FTMWqJyC/8jbL5R+P6Ka6calt8GOz8eDD+1WZpbmL3bYpHDTLx0Xp2ZXnrv\nOzGoyk+/gQ8H2TelrK/+2XBpfoe52QpTKx1f+ONRozW+iBvhYFNtT1oKPi44\nq+lRJQMmbLlJsXGj36evz6lwI4TVnYVT2UJTRlNs1zgWvhLbEuc1JaStLxo3\nw4zJ\r\n=TE1o\r\n-----END PGP SIGNATURE-----\r\n","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIDpROsF5WRONpzjV4P1728NCLpoVuKEOybWMTPiY+zKdAiEAqvs+xn0d//oC0wIHc0DU07Z9yO5B3gYcSMBlmMVAtYc="}]},"maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"_npmUser":{"name":"krystianity","email":"chris@5cf.de"},"directories":{},"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/kafka-streams_5.0.0_1582541070558_0.3059790963539948"},"_hasShrinkwrap":false}},"readme":"# node-kafka-streams\n\n[![Build Status](https://travis-ci.org/nodefluent/kafka-streams.svg?branch=master)](https://travis-ci.org/nodefluent/kafka-streams)\n[![npm version](https://badge.fury.io/js/kafka-streams.svg)](https://badge.fury.io/js/kafka-streams)\n\n```\n// suggested Node.js version: v12.16.1\nnpm install --save kafka-streams\n```\n\n```javascript\nconst {KafkaStreams} = require(\"kafka-streams\");\n\nconst config = require(\"./config.json\");\nconst factory = new KafkaStreams(config);\n\nconst kstream = factory.getKStream(\"input-topic\");\nconst ktable = factory.getKTable(/* .. */);\n\nkstream.merge(ktable).filter(/* .. */).map(/* .. */).reduce(/* .. */).to(\"output-topic\");\n```\n\n> CHANGES: The latest version brings a lot of changes, please check [here](CHANGELOG.md) before updating.\n\n## API Overview\n\n* [Quick Start](docs/quick-start.md)\n* [Message 'to' and 'from' Apache Kafka](docs/handling-messages-schemas.md)\n* [API Info](docs/api.md)\n* [Documentation](https://nodefluent.github.io/kafka-streams/jsdoc/)\n* [Operator descriptions](docs/most-api.md)\n* [Examples](https://github.com/nodefluent/kafka-streams/tree/master/examples)\n* [Native Client](docs/native.md) | [SSL, SASL, Kerberos](docs/ssl-sasl.md)\n\n## You might also like\n\n* [node-kafka-connect](https://github.com/nodefluent/kafka-connect)\n* [node-schema-registry](https://github.com/nodefluent/schema-registry)\n* [node-kafka-rest-ui](https://github.com/nodefluent/kafka-rest-ui)\n\n## README Overview\n\n* [Prerequisites](#prerequisites)\n* [Aim of this Library](#aim-of-this-library)\n* [Description](#description)\n* [Port Progress Overview](#port-progress-overview)\n* [Operator Implementations](#operator-implementations)\n* [Additional Operators](#additional-operators)\n* [Stream Action Implementations](#stream-action-implementations)\n* [Join Operators Status](#join-operations)\n* [Window Operations](#window-operations)\n* [FAQ - More](#more)\n\n## Prerequisites\n\n- Kafka broker should be version `>= 0.11.x`\n- Node.js should be version `>= 8.x.x`\n\n### A note on native mode\n\nIf you are using the native mode (`config: { noptions: {} }`).\nYou will have to manually install `node-rdkafka` alongside kafka-streams.\n(This requires a Node.js version between 9 and 12 and will not work with Node.js >= 13, last tested with 12.16.1)\n\nOn Mac OS High Sierra / Mojave:\n`CPPFLAGS=-I/usr/local/opt/openssl/include LDFLAGS=-L/usr/local/opt/openssl/lib yarn add --frozen-lockfile node-rdkafka@2.7.4`\n\nOtherwise:\n`yarn add --frozen-lockfile node-rdkafka@2.7.4`\n\n(Please also note: Doing this with npm does not work, it will remove your deps, `npm i -g yarn`)\n\n## Aim of this Library\n\n- this is not a 1:1 port of the official JAVA kafka-streams\n- the goal of this project is to give at least the same options to\na nodejs developer that kafka-streams provides for JVM developers\n- stream-state processing, table representation, joins, aggregate etc.\nI am aiming for the easiest api access possible checkout the [word count example](https://github.com/nodefluent/kafka-streams/blob/master/examples/wordCount.js)\n\n## Description\n\n[kafka-streams](http://docs.confluent.io/3.0.0/streams) :octopus: equivalent for nodejs :sparkles::turtle::rocket::sparkles:\nbuild on super fast :fire: observables using [most.js](https://github.com/cujojs/most) :metal:\n\nships with [sinek](https://github.com/nodefluent/node-sinek) :pray: for backpressure\n\ncomes with js and native Kafka client, for more performance and SSL, SASL and Kerberos features\n\nthe lib also comes with a few `window` operations that are more similar to [Apache Flink](https://flink.apache.org/),\nyet they still feel natural in this api :squirrel:\n\noverwriteable local-storage solution allows for any kind of datastore e.g. RocksDB, Redis, Postgres..\n\nasync (Promises) and sync stream operators e.g. `stream$.map()` or `stream$.asyncMap()`\n\nsuper easy API :goberserk:\n\nthe lib is based on `sinek`, which is based on kafka-node's `ConsumerGroups`\n\n## Port Progress Overview\n\n- [x] core structure\n- [x] KStream base - stream as a changelog\n- [x] KTable base - stream as a database\n- [x] KStream & KTable cloning\n- [x] complex stream join structure\n- [ ] advanced joins [see](#join-operations)\n- [ ] windows (for joins) [see](#join-operations)\n- [ ] flink like window operations\n- [x] word-count example\n- [x] more examples\n- [x] local-storage for etl actions\n- [x] local-storage factory (one per action)\n- [ ] KStorage example for any DB that supports atomic actions\n- [ ] backing-up local-storage via kafka\n- [x] kafka client implementation\n- [x] KTable replay to Kafka (produce)\n- [x] stream for topic message production only\n- [x] sinek implementation\n- [x] backpressure mode for KafkaClient\n- [x] auto-json payloads (read-map/write-map)\n- [x] auto producer partition and keyed-message handling\n- [x] documentation\n- [x] API description\n- [ ] higher join & combine examples\n- [x] embed native client `librdkafka` for more performance\n- [x] SSL\n- [x] SASL\n- [x] Kerberos\n\n\n## Operator Implementations\n\n- [x] map\n- [x] asyncMap\n- [x] constant\n- [x] scan\n- [x] timestamp\n- [x] tap\n- [x] filter\n- [x] skipRepeats\n- [x] skipRepeatsWith\n- [x] slice\n- [x] take\n- [x] skip\n- [x] takeWhile\n- [x] skipWhile\n- [x] until\n- [x] since\n- [x] reduce\n- [x] chainReduce\n- [x] forEach (observe)\n- [x] chainForEach\n- [x] drain\n- [x] _zip\n- [x] _merge\n- [x] _join\n- [x] _combine\n- [x] _sample\n- [x] throttle\n- [x] debounce\n- [x] delay\n- [x] multicast\n- A description of the operators can be found [here](docs/most-api.md)\n- Missing an operator? Feel free to open an issue :cop:\n\n## Additional Operators\n\n- [x] mapStringToArray\n- [x] mapArrayToKV\n- [x] mapStringToKV\n- [x] mapParse\n- [x] mapStringify\n- [x] atThroughput\n- [x] mapWrapKafkaPayload\n- [x] mapToFormat\n- [x] mapFromFormat\n- Want more? Feel free to open an issue :cop:\n\n## Stream Action Implementations\n\n- [x] countByKey\n- [x] sumByKey\n- [x] min\n- [x] max\n- Want more? Feel free to open an issue :cop:\n\n## Join Operations\n\n[Operation description](https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Streams+Join+Semantics)\n\n### KStream Status\n\n- [x] merge\n- [ ] outerJoin\n- [x] innerJoin\n- [ ] leftJoin\n- [x] branch\n\n### KTable Status\n\n- [x] merge\n- [ ] outerJoin\n- [ ] innerJoin\n- [ ] leftJoin\n\n### KTable <-> KStream Status\n\n- [x] merge\n- [ ] outerJoin\n- [ ] innerJoin\n- [ ] leftJoin\n\n## Window Operations\n\n### KStream\n\n- [x] window\n- [ ] advanced window\n- [ ] rolling window\n\n# More\n\n## Can I use this library yet?\n\nYes.\n\n## Are we ready for production yet?\n\nProbably, yes. :smile:\n\n## Even More\n\nForks or Stars give motivation :bowtie:\n","maintainers":[{"name":"krystianity","email":"chris@5cf.de"}],"time":{"modified":"2022-06-19T07:43:31.604Z","created":"2017-04-06T23:12:54.626Z","0.9.0":"2017-04-06T23:12:54.626Z","0.10.0":"2017-04-07T23:01:34.082Z","0.11.0":"2017-04-08T23:06:48.078Z","0.12.0":"2017-04-09T13:29:43.730Z","0.13.0":"2017-04-13T10:19:14.734Z","0.14.0":"2017-04-13T15:56:58.621Z","0.17.0":"2017-04-13T21:17:15.970Z","0.19.0":"2017-04-16T17:37:09.405Z","0.20.0":"2017-04-16T19:27:58.816Z","0.21.0":"2017-04-18T20:33:13.189Z","0.22.0":"2017-04-20T22:38:52.016Z","0.23.0":"2017-04-22T14:10:22.436Z","0.24.0":"2017-04-23T15:30:51.803Z","0.27.0":"2017-04-23T19:16:38.308Z","1.28.0":"2017-04-23T20:17:47.840Z","1.30.0":"2017-04-30T19:05:14.610Z","1.31.0":"2017-04-30T20:34:10.487Z","1.31.1":"2017-05-13T19:49:41.008Z","1.32.0":"2017-05-19T14:45:27.017Z","2.1.0":"2017-07-12T22:17:13.962Z","2.2.0":"2017-07-28T22:24:00.201Z","2.3.0":"2017-08-22T20:17:43.790Z","3.0.0":"2017-10-03T18:05:32.394Z","4.0.0":"2018-04-22T23:15:25.730Z","4.0.1":"2018-04-23T15:24:32.650Z","4.1.0":"2018-04-23T16:34:59.873Z","4.2.0":"2018-05-18T07:32:29.411Z","4.3.0":"2018-05-31T19:26:59.739Z","4.4.0":"2018-06-15T13:30:25.895Z","4.5.0":"2018-06-27T12:58:28.103Z","4.6.0":"2018-09-11T00:07:50.932Z","4.6.1":"2018-09-11T10:43:45.305Z","4.6.2":"2018-09-20T09:12:48.446Z","4.6.3":"2018-09-20T09:21:53.233Z","4.6.4":"2018-10-08T16:40:41.423Z","4.6.5":"2018-10-09T11:29:53.564Z","4.7.0":"2018-10-16T14:35:23.056Z","4.8.0":"2019-01-09T16:45:30.755Z","4.9.0":"2019-05-07T18:34:28.429Z","4.10.0":"2019-05-13T07:42:35.721Z","4.11.0":"2019-05-16T22:30:54.496Z","4.12.0":"2019-07-04T13:22:33.595Z","5.0.0":"2020-02-24T10:44:30.719Z"},"homepage":"https://github.com/nodefluent/kafka-streams#readme","keywords":["kafka-streams","kafka","streams","streaming","topics","produce","consume","merge","join","map","flat","filter","reduce","flink","window","combine"],"repository":{"type":"git","url":"git+https://github.com/nodefluent/kafka-streams.git"},"author":{"name":"Christian Froehlingsdorf","email":"chris@5cf.de"},"bugs":{"url":"https://github.com/nodefluent/kafka-streams/issues"},"license":"MIT","readmeFilename":"README.md","users":{"vidhill":true,"jagunr":true,"wkronmiller":true}}