{"_id":"kinesis-client-library","_rev":"29-2eba4bc9187db486037dc889903492bf","name":"kinesis-client-library","description":"Process Kinesis streams and automatically scale up or down as shards split or merge.","dist-tags":{"latest":"0.3.6","beta":"0.2.2"},"versions":{"0.1.0":{"name":"kinesis-client-library","version":"0.1.0","description":"Process Kinesis streams and automatically scale up or down as shards split or merge.","main":"index.js","scripts":{"test":"jshint *.js lib"},"author":{"name":"Evan Solomon"},"license":"MIT","bin":{"launch-kinesis-cluster":"./bin/launch"},"dependencies":{"async":"^0.9.0","aws-sdk":"^2.0.29","bunyan":"^1.2.3","minimist":"^1.1.0","underscore":"^1.7.0","vogels":"^0.12.0"},"devDependencies":{"jshint":"^2.5.10"},"gitHead":"12de23b975eee44529fa3058557184d5c2874af2","_id":"kinesis-client-library@0.1.0","_shasum":"f8be97f1428b81161530cd5439a9ea39018ddd1e","_from":".","_npmVersion":"1.4.28","_npmUser":{"name":"evansolomon","email":"evan@evanalyze.com"},"maintainers":[{"name":"evansolomon","email":"evan@evanalyze.com"}],"dist":{"shasum":"f8be97f1428b81161530cd5439a9ea39018ddd1e","tarball":"https://registry.npmjs.org/kinesis-client-library/-/kinesis-client-library-0.1.0.tgz","integrity":"sha512-kfwGjj7803UdguygHA372ggifnB+f83YWPB3qkZJ9f4ffoJebx42auyZyzwCXLMYfyd7Fr+HLscsbcy9jg/7uA==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDYezXQP8PzQxvNtCzm5ZJ1pqf2IrEfy1y43rLQfty0XAIgAUpZkSQGGeSLP6EKQYi6qU3fEgkyvlLfYpI64Je6t9k="}]}},"0.1.1":{"name":"kinesis-client-library","version":"0.1.1","description":"Process Kinesis streams and automatically scale up or down as shards split or merge.","main":"index.js","scripts":{"test":"jshint *.js lib"},"author":{"name":"Evan Solomon"},"license":"MIT","bin":{"launch-kinesis-cluster":"./bin/launch"},"homepage":"https://github.com/evansolomon/nodejs-kinesis-client-library","repository":{"type":"git","url":"git://github.com/evansolomon/nodejs-kinesis-client-library.git"},"bugs":{"url":"https://github.com/evansolomon/nodejs-kinesis-client-library/issues"},"keywords":["aws","kinesis"],"dependencies":{"async":"^0.9.0","aws-sdk":"^2.0.29","bunyan":"^1.2.3","minimist":"^1.1.0","underscore":"^1.7.0","vogels":"^0.12.0"},"devDependencies":{"jshint":"^2.5.10"},"gitHead":"b5c5094259f85609609e68604cd14256a3ffbfc1","_id":"kinesis-client-library@0.1.1","_shasum":"66203586ab8bac6212a7c2666649aa8f8ec60180","_from":".","_npmVersion":"1.4.28","_npmUser":{"name":"evansolomon","email":"evan@evanalyze.com"},"maintainers":[{"name":"evansolomon","email":"evan@evanalyze.com"}],"dist":{"shasum":"66203586ab8bac6212a7c2666649aa8f8ec60180","tarball":"https://registry.npmjs.org/kinesis-client-library/-/kinesis-client-library-0.1.1.tgz","integrity":"sha512-CPyEYIxKTIJGvNtfPnEs0HtwfAcqqLQ5+i2BKZeVoVSPnreC1w+Kv6vuLiaurdV/r3wDrmkhYAOOVvGgexBZ/w==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIBj9zD2amSAh2+uQ3IIMvko7C0rA0RMy1yg2Dq8SXTs7AiB5DkHqiEQyEcUsKz51jOg5/NqRBDuHC4E378MGea78Wg=="}]}},"0.2.0":{"name":"kinesis-client-library","version":"0.2.0","description":"Process Kinesis streams and automatically scale up or down as shards split or merge.","main":"index.js","scripts":{"test":"jshint *.js lib"},"author":{"name":"Evan Solomon"},"license":"MIT","bin":{"launch-kinesis-cluster":"./bin/launch"},"homepage":"https://github.com/evansolomon/nodejs-kinesis-client-library","repository":{"type":"git","url":"git://github.com/evansolomon/nodejs-kinesis-client-library.git"},"bugs":{"url":"https://github.com/evansolomon/nodejs-kinesis-client-library/issues"},"keywords":["aws","kinesis"],"dependencies":{"async":"^0.9.0","aws-sdk":"^2.0.29","bunyan":"^1.2.3","local-dynamo":"0.0.3","minimist":"^1.1.0","mkdirp":"^0.5.0","underscore":"^1.7.0","vogels":"^0.12.0"},"devDependencies":{"jshint":"^2.5.10"},"gitHead":"00f19a199a013554e39c6de70774c330d0dfc932","_id":"kinesis-client-library@0.2.0","_shasum":"2ce40eb8f55cbc7e0b48841d7f1d3252d8b2aae7","_from":".","_npmVersion":"1.4.28","_npmUser":{"name":"evansolomon","email":"evan@evanalyze.com"},"maintainers":[{"name":"evansolomon","email":"evan@evanalyze.com"}],"dist":{"shasum":"2ce40eb8f55cbc7e0b48841d7f1d3252d8b2aae7","tarball":"https://registry.npmjs.org/kinesis-client-library/-/kinesis-client-library-0.2.0.tgz","integrity":"sha512-nUh1yaP8Fi7iw55RCMhxVuq03rm55ha5eLzxulVH85atTdj5Ilj5R82RiUQzc1WK2OjI/AB6CYw5i/WopEzg8A==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQCXfvraLR6PyjVpm5LgbueM6jZGz3TSmv0JGtXa4nK6uQIgE5XJf8/AKT5Ke0i4PjqyJVarFF/Tah9wvkNDr8F8FdA="}]}},"0.2.1":{"name":"kinesis-client-library","version":"0.2.1","description":"Process Kinesis streams and automatically scale up or down as shards split or merge.","main":"index.js","scripts":{"test":"jshint *.js lib"},"author":{"name":"Evan Solomon"},"license":"MIT","bin":{"launch-kinesis-cluster":"./bin/launch"},"homepage":"https://github.com/evansolomon/nodejs-kinesis-client-library","repository":{"type":"git","url":"git://github.com/evansolomon/nodejs-kinesis-client-library.git"},"bugs":{"url":"https://github.com/evansolomon/nodejs-kinesis-client-library/issues"},"keywords":["aws","kinesis"],"dependencies":{"async":"^0.9.0","aws-sdk":"^2.0.29","bunyan":"^1.2.3","local-dynamo":"0.0.3","minimist":"^1.1.0","mkdirp":"^0.5.0","underscore":"^1.7.0","vogels":"^0.12.0"},"devDependencies":{"jshint":"^2.5.10"},"gitHead":"d893e62e244e2202a9444bb2686cba40a15deeaf","_id":"kinesis-client-library@0.2.1","_shasum":"178a9638e8704976c8a248633381fdc02eda62da","_from":".","_npmVersion":"1.4.28","_npmUser":{"name":"evansolomon","email":"evan@evanalyze.com"},"maintainers":[{"name":"evansolomon","email":"evan@evanalyze.com"}],"dist":{"shasum":"178a9638e8704976c8a248633381fdc02eda62da","tarball":"https://registry.npmjs.org/kinesis-client-library/-/kinesis-client-library-0.2.1.tgz","integrity":"sha512-WScpgHT8Nd8F6ge+5c4TH6R8JJIAQJMvTngX/SOw4of4sIurkKSenns6G6yN1KhGWdx8i16l28kUjUXLAx/58w==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCkXhtf2+RqZU2RtK2zRbQNv3ww0fsCq8T8fi6QWCW3TAIhAJa2QpXqzG4c1gIPA2jzKhPxb9MJ20ar1xYJ2/rkf+lg"}]},"deprecated":"Fixed incorrect method calls in 0.2.2"},"0.2.2":{"name":"kinesis-client-library","version":"0.2.2","description":"Process Kinesis streams and automatically scale up or down as shards split or merge.","main":"index.js","scripts":{"test":"jshint *.js lib"},"author":{"name":"Evan Solomon"},"license":"MIT","bin":{"launch-kinesis-cluster":"./bin/launch"},"homepage":"https://github.com/evansolomon/nodejs-kinesis-client-library","repository":{"type":"git","url":"git://github.com/evansolomon/nodejs-kinesis-client-library.git"},"bugs":{"url":"https://github.com/evansolomon/nodejs-kinesis-client-library/issues"},"keywords":["aws","kinesis"],"dependencies":{"async":"^0.9.0","aws-sdk":"^2.0.29","bunyan":"^1.2.3","local-dynamo":"0.0.3","minimist":"^1.1.0","mkdirp":"^0.5.0","underscore":"^1.7.0","vogels":"^0.12.0"},"devDependencies":{"jshint":"^2.5.10"},"gitHead":"3c065dd9f993123abaf96625bd54043ae86252c1","_id":"kinesis-client-library@0.2.2","_shasum":"521d0fb7dd285ea348738e1369b479c3d403d329","_from":".","_npmVersion":"1.4.28","_npmUser":{"name":"evansolomon","email":"evan@evanalyze.com"},"maintainers":[{"name":"evansolomon","email":"evan@evanalyze.com"}],"dist":{"shasum":"521d0fb7dd285ea348738e1369b479c3d403d329","tarball":"https://registry.npmjs.org/kinesis-client-library/-/kinesis-client-library-0.2.2.tgz","integrity":"sha512-iCweCMZOJLFjrQLwpND8KP11ToxYQrvXbzWZASIP0Z030s7UZJrfBPNesOGvlDXAIN2eSaSx2kzlPHMe3Sx2Iw==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCoRFINkXVdWQCyTQk+mfZR52z8Makl1rcS0YQJxOcyaQIhALfJN3bILEKWpzOue0XN8fC0nNhYyegoXCgfBPi3pj7O"}]}},"0.2.3":{"name":"kinesis-client-library","version":"0.2.3","description":"Process Kinesis streams and automatically scale up or down as shards split or merge.","main":"index.js","scripts":{"test":"jshint *.js lib"},"author":{"name":"Evan Solomon"},"license":"MIT","bin":{"launch-kinesis-cluster":"./bin/launch"},"homepage":"https://github.com/evansolomon/nodejs-kinesis-client-library","repository":{"type":"git","url":"git://github.com/evansolomon/nodejs-kinesis-client-library.git"},"bugs":{"url":"https://github.com/evansolomon/nodejs-kinesis-client-library/issues"},"keywords":["aws","kinesis"],"dependencies":{"async":"^0.9.0","aws-sdk":"^2.0.29","bunyan":"^1.2.3","local-dynamo":"0.0.3","minimist":"^1.1.0","mkdirp":"^0.5.0","underscore":"^1.7.0","vogels":"^0.12.0"},"devDependencies":{"jshint":"^2.5.10"},"gitHead":"84ea665cc5947a11a6dd8a16a9ed0bfec9d4bc1b","_id":"kinesis-client-library@0.2.3","_shasum":"260116bf0c5fdcf0a6941704a75856c843f238b0","_from":".","_npmVersion":"2.5.1","_nodeVersion":"0.12.0","_npmUser":{"name":"evansolomon","email":"evan@evanalyze.com"},"maintainers":[{"name":"evansolomon","email":"evan@evanalyze.com"}],"dist":{"shasum":"260116bf0c5fdcf0a6941704a75856c843f238b0","tarball":"https://registry.npmjs.org/kinesis-client-library/-/kinesis-client-library-0.2.3.tgz","integrity":"sha512-A/1RzPknGHIlRRlUS8ILK8Zck+GNfLf1foCnMCzgCKUg6DsUKwvrnS0BzvPSh24qfeJF/LHxLzaiIeMima+7SQ==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCvZeVA/CnKpKhNzjjwH7KRq8IpY1zE/pPHV5yW5oqcDgIhAMyYWKu0mafvonS6QYRiRC7kyoKwiY4F0kVklHiGRp+g"}]}},"0.2.4":{"name":"kinesis-client-library","version":"0.2.4","description":"Process Kinesis streams and automatically scale up or down as shards split or merge.","main":"build/index.js","scripts":{"test":"mocha","clean":"rm -rf build","build":"npm run clean && npm run typescript-definitions && npm run typescript","typescript-definitions":"tsd reinstall && tsd rebundle","typescript":"tsc src/*.ts src/**/*.ts build/.typings/tsd.d.ts --module commonjs --outDir build --declaration","prepublish":"npm run build"},"author":{"name":"Evan Solomon"},"license":"MIT","bin":{"launch-kinesis-cluster":"./bin/launch"},"homepage":"https://github.com/evansolomon/nodejs-kinesis-client-library","repository":{"type":"git","url":"git://github.com/evansolomon/nodejs-kinesis-client-library.git"},"bugs":{"url":"https://github.com/evansolomon/nodejs-kinesis-client-library/issues"},"keywords":["aws","kinesis"],"dependencies":{"async":"^0.9.0","aws-sdk":"^2.0.29","bunyan":"^1.2.3","kinesalite":"^1.0.2","local-dynamo":"0.0.3","minimist":"^1.1.0","mkdirp":"^0.5.0","underscore":"^1.7.0","vogels":"^0.12.0"},"devDependencies":{"jshint":"^2.5.10","mocha":"^2.2.1","tsd":"^0.6.0-beta.5","typescript":"^1.4.1"},"gitHead":"1b53e2b5b58b4144b2a7cea332e4e1aaac682585","_id":"kinesis-client-library@0.2.4","_shasum":"94b04eb9758fc86d1defaa98b04a803c1a3d385a","_from":".","_npmVersion":"2.5.1","_nodeVersion":"0.12.0","_npmUser":{"name":"evansolomon","email":"evan@evanalyze.com"},"maintainers":[{"name":"evansolomon","email":"evan@evanalyze.com"}],"dist":{"shasum":"94b04eb9758fc86d1defaa98b04a803c1a3d385a","tarball":"https://registry.npmjs.org/kinesis-client-library/-/kinesis-client-library-0.2.4.tgz","integrity":"sha512-ey2OxyDCydyxBHxYMSArA+f90mm/Z9gZw5Epqbb4MQjnaI412miW6HwL/S4gefIPSzwrJhVl6+FoRI1RpnT6bA==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCj2RqgcZY8LMI0Xaho6v02UhswUaV9cew/Rnn61nkrvgIhALO3BIoelycLF3NiYsU6JVYyI5Nso4mnw0enVaEUJNvi"}]}},"0.2.5":{"name":"kinesis-client-library","version":"0.2.5","description":"Process Kinesis streams and automatically scale up or down as shards split or merge.","main":"build/index.js","scripts":{"test":"mocha","clean":"rm -rf build","build":"npm run clean && npm run typescript-definitions && npm run typescript","typescript-definitions":"tsd reinstall && tsd rebundle","typescript":"tsc src/*.ts src/**/*.ts build/.typings/tsd.d.ts --module commonjs --outDir build --declaration","prepublish":"npm run build"},"author":{"name":"Evan Solomon"},"license":"MIT","bin":{"launch-kinesis-cluster":"./bin/launch"},"homepage":"https://github.com/evansolomon/nodejs-kinesis-client-library","repository":{"type":"git","url":"git://github.com/evansolomon/nodejs-kinesis-client-library.git"},"bugs":{"url":"https://github.com/evansolomon/nodejs-kinesis-client-library/issues"},"keywords":["aws","kinesis"],"dependencies":{"async":"^0.9.0","aws-sdk":"^2.0.29","bunyan":"^1.2.3","kinesalite":"^1.0.2","local-dynamo":"0.0.3","minimist":"^1.1.0","mkdirp":"^0.5.0","underscore":"^1.7.0","vogels":"^0.12.0"},"devDependencies":{"jshint":"^2.5.10","mocha":"^2.2.1","tsd":"^0.6.0-beta.5","typescript":"^1.4.1"},"gitHead":"2037a1139e647da0654673c777e1c142e9dd85ec","_id":"kinesis-client-library@0.2.5","_shasum":"06d3f46c5463816b46e40c9fe2298aafeb20b0b2","_from":".","_npmVersion":"2.5.1","_nodeVersion":"0.12.0","_npmUser":{"name":"evansolomon","email":"evan@evanalyze.com"},"maintainers":[{"name":"evansolomon","email":"evan@evanalyze.com"}],"dist":{"shasum":"06d3f46c5463816b46e40c9fe2298aafeb20b0b2","tarball":"https://registry.npmjs.org/kinesis-client-library/-/kinesis-client-library-0.2.5.tgz","integrity":"sha512-UydeR2Y/24eQLek96WyjsiMe/Zo8B7qhGw5nCFINgT9q7EsLjDGcJwPbcTWqLshPTn6ku8YNeYKe6WRtwbDa0g==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIEtYvESBYacBCML+RJgO40UJtljrcJmdrM4gStUU9DI0AiEAo99+8qYQ46iwvAblgQYTzqxlwCrn0YPhY50InLlwi9g="}]}},"0.2.6":{"name":"kinesis-client-library","version":"0.2.6","description":"Process Kinesis streams and automatically scale up or down as shards split or merge.","main":"build/index.js","scripts":{"test":"mocha","clean":"rm -rf build","build":"npm run clean && npm run typescript-definitions && npm run typescript","typescript-definitions":"tsd reinstall && tsd rebundle","typescript":"tsc src/*.ts src/**/*.ts build/.typings/tsd.d.ts --module commonjs --outDir build --declaration","prepublish":"npm run build"},"author":{"name":"Evan Solomon"},"license":"MIT","bin":{"launch-kinesis-cluster":"./bin/launch"},"homepage":"https://github.com/evansolomon/nodejs-kinesis-client-library","repository":{"type":"git","url":"git://github.com/evansolomon/nodejs-kinesis-client-library.git"},"bugs":{"url":"https://github.com/evansolomon/nodejs-kinesis-client-library/issues"},"keywords":["aws","kinesis"],"dependencies":{"async":"^0.9.0","aws-sdk":"^2.0.29","bunyan":"^1.2.3","kinesalite":"^1.0.2","local-dynamo":"0.0.3","minimist":"^1.1.0","mkdirp":"^0.5.0","underscore":"^1.7.0","vogels":"^0.12.0"},"devDependencies":{"jshint":"^2.5.10","mocha":"^2.2.1","tsd":"^0.6.0-beta.5","typescript":"^1.4.1"},"gitHead":"56657f7006a47f08d1aadcad9f0fc3055d33539c","_id":"kinesis-client-library@0.2.6","_shasum":"ee92192d5a92a196c9ae338dfd28f5c5d0808ec3","_from":".","_npmVersion":"2.5.1","_nodeVersion":"0.12.0","_npmUser":{"name":"evansolomon","email":"evan@evanalyze.com"},"dist":{"shasum":"ee92192d5a92a196c9ae338dfd28f5c5d0808ec3","tarball":"https://registry.npmjs.org/kinesis-client-library/-/kinesis-client-library-0.2.6.tgz","integrity":"sha512-YxZu/VvOqrMLmpWJIEGAP9v91T2Zn5DbIu9DaCLQM7tniMFqNVOpUdJ52alfTBpjx/0hRQ9hCKwbFidW9+u2jw==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQCgtvCdgT3OR4F9aW01Z1z/FMAcPLWUUORaEbFfQcbG5gIgGpHYYSE6iHozru+ZpFVwY/Q0xc02FOfbiKbyvKAl9ZY="}]},"maintainers":[{"name":"evansolomon","email":"evan@evanalyze.com"}]},"0.2.7":{"name":"kinesis-client-library","version":"0.2.7","description":"Process Kinesis streams and automatically scale up or down as shards split or merge.","main":"build/index.js","scripts":{"test":"mocha","clean":"rm -rf build","build":"npm run clean && npm run typescript-definitions && npm run typescript","typescript-definitions":"tsd reinstall && tsd rebundle","typescript":"tsc src/*.ts src/**/*.ts build/.typings/tsd.d.ts --module commonjs --outDir build --declaration","prepublish":"npm run build"},"author":{"name":"Evan Solomon"},"license":"MIT","bin":{"launch-kinesis-cluster":"./bin/launch"},"homepage":"https://github.com/evansolomon/nodejs-kinesis-client-library","repository":{"type":"git","url":"git://github.com/evansolomon/nodejs-kinesis-client-library.git"},"bugs":{"url":"https://github.com/evansolomon/nodejs-kinesis-client-library/issues"},"keywords":["aws","kinesis"],"dependencies":{"async":"^0.9.0","aws-sdk":"^2.0.29","bunyan":"^1.2.3","kinesalite":"^1.0.2","local-dynamo":"0.0.3","minimist":"^1.1.0","mkdirp":"^0.5.0","underscore":"^1.7.0","vogels":"^0.12.0"},"devDependencies":{"jshint":"^2.5.10","mocha":"^2.2.1","tsd":"^0.6.0-beta.5","typescript":"^1.4.1"},"gitHead":"dcc160335122b8c64e67f6a8c49ae0d8080953a7","_id":"kinesis-client-library@0.2.7","_shasum":"738c12948df0eee09f6c7f7847639928b3027854","_from":".","_npmVersion":"2.8.4","_nodeVersion":"0.12.0","_npmUser":{"name":"evansolomon","email":"evan@evanalyze.com"},"dist":{"shasum":"738c12948df0eee09f6c7f7847639928b3027854","tarball":"https://registry.npmjs.org/kinesis-client-library/-/kinesis-client-library-0.2.7.tgz","integrity":"sha512-8s3pV44BI4u+jXHod/6Led1OGYHnZ8xD6yHcMmBsmhZmPRLz9pxgzelh6kIdshwjBvHUD3P/OvY3vNHOMIaRfQ==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCZS9AddmeSti6c6fMRfUqyqwTPtH1LVbxcJSqK8t3L4gIhAJC7L0jRC511YX8I489fHsrqrJQxOaqkJPurt1Zmd9gB"}]},"maintainers":[{"name":"evansolomon","email":"evan@evanalyze.com"}]},"0.3.0":{"name":"kinesis-client-library","version":"0.3.0","description":"Process Kinesis streams and automatically scale up or down as shards split or merge.","main":"build/index.js","scripts":{"test":"mocha","clean":"rm -rf build","build":"npm run clean && npm run typescript-definitions && npm run typescript","typescript-definitions":"tsd reinstall && tsd rebundle","typescript":"tsc src/*.ts src/**/*.ts build/.typings/tsd.d.ts --module commonjs --outDir build --declaration","prepublish":"npm run build"},"author":{"name":"Evan Solomon"},"license":"MIT","bin":{"launch-kinesis-cluster":"./bin/launch"},"homepage":"https://github.com/evansolomon/nodejs-kinesis-client-library","repository":{"type":"git","url":"git://github.com/evansolomon/nodejs-kinesis-client-library.git"},"bugs":{"url":"https://github.com/evansolomon/nodejs-kinesis-client-library/issues"},"keywords":["aws","kinesis"],"dependencies":{"async":"^0.9.0","aws-sdk":"^2.0.29","bunyan":"^1.2.3","kinesalite":"^1.0.2","local-dynamo":"0.0.3","minimist":"^1.1.0","mkdirp":"^0.5.0","underscore":"^1.7.0","vogels":"^0.12.0"},"devDependencies":{"jshint":"^2.5.10","mocha":"^2.2.1","tsd":"^0.6.0-beta.5","typescript":"^1.4.1"},"gitHead":"3b260cad38a152c337533e76340c5dfab1690c05","_id":"kinesis-client-library@0.3.0","_shasum":"e5f807e5bcdf9d49f030d71e8445d512a8a3a51d","_from":".","_npmVersion":"2.13.2","_nodeVersion":"2.5.0","_npmUser":{"name":"evansolomon","email":"evan@evanalyze.com"},"dist":{"shasum":"e5f807e5bcdf9d49f030d71e8445d512a8a3a51d","tarball":"https://registry.npmjs.org/kinesis-client-library/-/kinesis-client-library-0.3.0.tgz","integrity":"sha512-/AwM+k+nXwS3SrAnh6YdmBFtyQe+NN5BvkKmcN5bo6Z/hf8raSf8WnOuWe6JYuUJejri1Yi3GqfWOFX9py9wQw==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIF9dmypqbn79UUbuUJi7xjLDSnpnQD9AQIrjT6Xc+KRQAiEA4HDbZ0uVZ7NpDnr9iyEscIh+J5bdJzIHsPDEgurO+yE="}]},"maintainers":[{"name":"evansolomon","email":"evan@evanalyze.com"}]},"0.3.1":{"name":"kinesis-client-library","version":"0.3.1","description":"Process Kinesis streams and automatically scale up or down as shards split or merge.","main":"build/index.js","scripts":{"test":"mocha","clean":"rm -rf build","build":"npm run clean && npm run typescript-definitions && npm run typescript","typescript-definitions":"tsd reinstall && tsd rebundle","typescript":"tsc src/*.ts src/**/*.ts build/.typings/tsd.d.ts --module commonjs --outDir build --declaration","prepublish":"npm run build"},"author":{"name":"Evan Solomon"},"license":"MIT","bin":{"launch-kinesis-cluster":"./bin/launch"},"homepage":"https://github.com/evansolomon/nodejs-kinesis-client-library","repository":{"type":"git","url":"git://github.com/evansolomon/nodejs-kinesis-client-library.git"},"bugs":{"url":"https://github.com/evansolomon/nodejs-kinesis-client-library/issues"},"keywords":["aws","kinesis"],"dependencies":{"async":"^0.9.0","aws-sdk":"^2.0.29","bunyan":"^1.2.3","kinesalite":"^1.0.2","local-dynamo":"0.0.3","minimist":"^1.1.0","mkdirp":"^0.5.0","underscore":"^1.7.0","vogels":"^0.12.0"},"devDependencies":{"jshint":"^2.5.10","mocha":"^2.2.1","tsd":"^0.6.0-beta.5","typescript":"^1.4.1"},"gitHead":"e8a21097824139af820d08262468f84956ea0dc6","_id":"kinesis-client-library@0.3.1","_shasum":"271d4d9ea2fb7860cf9dd7ed4d4762573fcd5344","_from":".","_npmVersion":"2.13.5","_nodeVersion":"2.5.0","_npmUser":{"name":"evansolomon","email":"evan@evanalyze.com"},"dist":{"shasum":"271d4d9ea2fb7860cf9dd7ed4d4762573fcd5344","tarball":"https://registry.npmjs.org/kinesis-client-library/-/kinesis-client-library-0.3.1.tgz","integrity":"sha512-nbksZqpCKSnbhzENGXb3Rs+W8iUZ5EAz4DS/SjqEidkYuweWkNn7iuR+T9yhKG/1/DOJYGO3QkQ0uXaZtGIYsQ==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDfICwzXYzmbIqFMCxacEgvmaDqYvSVryC5jfndMoOCFgIgF2PkQT6a3M2APiMKbUJmnC3cK70xsB5ciOguQ92hCeY="}]},"maintainers":[{"name":"evansolomon","email":"evan@evanalyze.com"}]},"0.3.2":{"name":"kinesis-client-library","version":"0.3.2","description":"Process Kinesis streams and automatically scale up or down as shards split or merge.","main":"build/index.js","scripts":{"test":"mocha","clean":"rm -rf build","build":"npm run clean && npm run typescript-definitions && npm run typescript","typescript-definitions":"tsd reinstall && tsd rebundle","typescript":"tsc src/*.ts src/**/*.ts build/.typings/tsd.d.ts --module commonjs --outDir build --declaration","prepublish":"npm run build"},"author":{"name":"Evan Solomon"},"license":"MIT","bin":{"launch-kinesis-cluster":"./bin/launch"},"homepage":"https://github.com/evansolomon/nodejs-kinesis-client-library","repository":{"type":"git","url":"git://github.com/evansolomon/nodejs-kinesis-client-library.git"},"bugs":{"url":"https://github.com/evansolomon/nodejs-kinesis-client-library/issues"},"keywords":["aws","kinesis"],"dependencies":{"async":"^0.9.0","aws-sdk":"^2.0.29","bunyan":"^1.2.3","kinesalite":"^1.0.2","local-dynamo":"0.0.3","minimist":"^1.1.0","mkdirp":"^0.5.0","underscore":"^1.7.0","vogels":"^0.12.0"},"devDependencies":{"jshint":"^2.5.10","mocha":"^2.2.1","tsd":"^0.6.0-beta.5","typescript":"^1.4.1"},"gitHead":"65e7ebc3d002315f1c1da8083e5e6d1808e8be23","_id":"kinesis-client-library@0.3.2","_shasum":"6b0dc63a997909e417fb65bf98b6a2576419ff13","_from":".","_npmVersion":"2.13.5","_nodeVersion":"2.5.0","_npmUser":{"name":"evansolomon","email":"evan@evanalyze.com"},"dist":{"shasum":"6b0dc63a997909e417fb65bf98b6a2576419ff13","tarball":"https://registry.npmjs.org/kinesis-client-library/-/kinesis-client-library-0.3.2.tgz","integrity":"sha512-2RwBQehS2jOvzpXrZypJPS0anFn+EI+WchdbE5BnOXizMA/ecHd7ons0D53KwCVDoBk3Q+ZKO3mKgsc0d91vZg==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIF1BsHfRtmz5lBAFfTrJIhgWVqKZyDQQCANqjZbDIg5SAiBNDZP/0ZmxoJcqbcTt+F+4vAkoxsUrEZMWA7Jw/acQ1A=="}]},"maintainers":[{"name":"evansolomon","email":"evan@evanalyze.com"}]},"0.3.3":{"name":"kinesis-client-library","version":"0.3.3","description":"Process Kinesis streams and automatically scale up or down as shards split or merge.","main":"build/index.js","scripts":{"test":"mocha","clean":"rm -rf build","build":"npm run clean && npm run typescript-definitions && npm run typescript","typescript-definitions":"tsd reinstall && tsd rebundle","typescript":"tsc src/*.ts src/**/*.ts build/.typings/tsd.d.ts --module commonjs --outDir build --declaration","prepublish":"npm run build"},"author":{"name":"Evan Solomon"},"license":"MIT","bin":{"launch-kinesis-cluster":"./bin/launch"},"homepage":"https://github.com/evansolomon/nodejs-kinesis-client-library","repository":{"type":"git","url":"git://github.com/evansolomon/nodejs-kinesis-client-library.git"},"bugs":{"url":"https://github.com/evansolomon/nodejs-kinesis-client-library/issues"},"keywords":["aws","kinesis"],"dependencies":{"async":"^0.9.0","aws-sdk":"^2.0.29","bunyan":"^1.2.3","kinesalite":"^1.0.2","local-dynamo":"0.0.3","minimist":"^1.1.0","mkdirp":"^0.5.0","underscore":"^1.7.0","vogels":"^0.12.0"},"devDependencies":{"jshint":"^2.5.10","mocha":"^2.2.1","tsd":"^0.6.0-beta.5","typescript":"^1.4.1"},"gitHead":"8bf7845caf20336fbe0a5a38e19ef3258dce73e8","_id":"kinesis-client-library@0.3.3","_shasum":"7496472c7198edcd97c3d682b41be6b5a54446ed","_from":".","_npmVersion":"2.13.5","_nodeVersion":"2.5.0","_npmUser":{"name":"evansolomon","email":"evan@evanalyze.com"},"dist":{"shasum":"7496472c7198edcd97c3d682b41be6b5a54446ed","tarball":"https://registry.npmjs.org/kinesis-client-library/-/kinesis-client-library-0.3.3.tgz","integrity":"sha512-hvivm77hEXrfxRxzLeKjz7M7buYt9+s65DKKrqSOvRx9jjjyRzfbKxgDuXZfXs265rGkYYI5WWj5fDS+vPimeg==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQC6vHLTlLcSNWhOX0dcE0gw2SRA76jS4KZ+LAvhNbxiCAIhAJXmOaZvYlDs5P06f34hyKpyl4Pxdc0FYqcWwp3P8LPh"}]},"maintainers":[{"name":"evansolomon","email":"evan@evanalyze.com"}]},"0.3.4":{"name":"kinesis-client-library","version":"0.3.4","description":"Process Kinesis streams and automatically scale up or down as shards split or merge.","main":"build/index.js","scripts":{"test":"mocha","clean":"rm -rf build","build":"npm run clean && npm run typescript-definitions && npm run typescript","typescript-definitions":"tsd reinstall && tsd rebundle","typescript":"tsc src/*.ts src/**/*.ts build/.typings/tsd.d.ts --module commonjs --outDir build --declaration","prepublish":"npm run build"},"author":{"name":"Evan Solomon"},"license":"MIT","bin":{"launch-kinesis-cluster":"./bin/launch"},"homepage":"https://github.com/evansolomon/nodejs-kinesis-client-library","repository":{"type":"git","url":"git://github.com/evansolomon/nodejs-kinesis-client-library.git"},"bugs":{"url":"https://github.com/evansolomon/nodejs-kinesis-client-library/issues"},"keywords":["aws","kinesis"],"dependencies":{"async":"^0.9.0","aws-sdk":"^2.0.29","bunyan":"^1.2.3","kinesalite":"^1.0.2","local-dynamo":"0.0.3","minimist":"^1.1.0","mkdirp":"^0.5.0","underscore":"^1.7.0","vogels":"^0.12.0"},"devDependencies":{"jshint":"^2.5.10","mocha":"^2.2.1","tsd":"^0.6.0-beta.5","typescript":"^1.4.1"},"gitHead":"dd7e673d729ff55a6ae655a34ff3076beda99a96","_id":"kinesis-client-library@0.3.4","_shasum":"1629e33d0ac4e5e9a464baf0419d73e28e7671b5","_from":".","_npmVersion":"2.13.5","_nodeVersion":"2.5.0","_npmUser":{"name":"evansolomon","email":"evan@evanalyze.com"},"dist":{"shasum":"1629e33d0ac4e5e9a464baf0419d73e28e7671b5","tarball":"https://registry.npmjs.org/kinesis-client-library/-/kinesis-client-library-0.3.4.tgz","integrity":"sha512-uWkO2AQS+QjX07ra4mgs6jI0jN7Lp0uKO/c2LXavmPQ2myrQ8sFcTyyEX6SMNsvCHemNYLQUeZiMzoPK43c18A==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQCXuPL6wQ9rTGy6DnIom5HervbUsFtnCZZJoDZjGb1RMgIgOhr24bLxuIOrMwtKGASroWICRPELogNka0sddYYQAC4="}]},"maintainers":[{"name":"evansolomon","email":"evan@evanalyze.com"}]},"0.3.5":{"name":"kinesis-client-library","version":"0.3.5","description":"Process Kinesis streams and automatically scale up or down as shards split or merge.","main":"build/index.js","scripts":{"test":"npm run lint && mocha","quick-test":"npm run typescript && npm run lint","lint":"tslint src/**/*.ts","clean":"rm -rf build","build":"npm run clean && npm run typescript-definitions && npm run typescript","typescript-definitions":"tsd reinstall && tsd rebundle","typescript":"tsc src/*.ts src/**/*.ts build/.typings/tsd.d.ts --module commonjs --outDir build --declaration","prepublish":"npm run build"},"author":{"name":"Evan Solomon"},"license":"MIT","bin":{"launch-kinesis-cluster":"./bin/launch"},"homepage":"https://github.com/evansolomon/nodejs-kinesis-client-library","repository":{"type":"git","url":"git://github.com/evansolomon/nodejs-kinesis-client-library.git"},"bugs":{"url":"https://github.com/evansolomon/nodejs-kinesis-client-library/issues"},"keywords":["aws","kinesis"],"dependencies":{"async":"^0.9.0","aws-sdk":"^2.0.29","bunyan":"^1.2.3","kinesalite":"^1.0.2","local-dynamo":"0.0.3","minimist":"^1.1.0","mkdirp":"^0.5.0","underscore":"^1.7.0","vogels":"^0.12.0"},"devDependencies":{"jshint":"^2.5.10","mocha":"^2.2.1","tsd":"^0.6.0-beta.5","tslint":"^2.4.4","typescript":"~1.5.3"},"gitHead":"829dceecd8e69d597627fbb396f4d5f36a517397","_id":"kinesis-client-library@0.3.5","_shasum":"b1a16e6897008caf45526586ad915e30b715129e","_from":".","_npmVersion":"2.14.15","_nodeVersion":"5.3.0","_npmUser":{"name":"evansolomon","email":"evan@evanalyze.com"},"dist":{"shasum":"b1a16e6897008caf45526586ad915e30b715129e","tarball":"https://registry.npmjs.org/kinesis-client-library/-/kinesis-client-library-0.3.5.tgz","integrity":"sha512-/EPNTU+BKQmtAHTk3YkqrtJ+geAu0DYO/5okiDe7RSFhYEZBgWsCEVJXESjSv+1w1E9iyE9CI3inMHyrjk4bng==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQD3TOhrVRowLGvRVTnvPYZNu8RnOJYYla1yh+XhlelOVAIhAL4H1/DGTtB/lfkgXLRn+jJd3jrFFYlk0YeDXq22Hrf3"}]},"maintainers":[{"name":"evansolomon","email":"evan@evanalyze.com"}],"_npmOperationalInternal":{"host":"packages-12-west.internal.npmjs.com","tmp":"tmp/kinesis-client-library-0.3.5.tgz_1457490116414_0.5638603987172246"}},"0.3.6":{"name":"kinesis-client-library","version":"0.3.6","description":"Process Kinesis streams and automatically scale up or down as shards split or merge.","main":"build/index.js","typings":"build/index","scripts":{"test":"npm run lint && mocha","quick-test":"tsc && npm run lint","lint":"tslint src/*.ts src/lib/**/*.ts","clean":"rm -rf build","build":"npm run clean && npm run tsd && tsc","tsd-clean":"rm -rf src/typings","tsd":"npm run tsd-clean && tsd reinstall && tsd rebundle","prepublish":"npm run build"},"author":{"name":"Evan Solomon"},"license":"MIT","bin":{"launch-kinesis-cluster":"./bin/launch"},"homepage":"https://github.com/evansolomon/nodejs-kinesis-client-library","repository":{"type":"git","url":"git://github.com/evansolomon/nodejs-kinesis-client-library.git"},"bugs":{"url":"https://github.com/evansolomon/nodejs-kinesis-client-library/issues"},"keywords":["aws","kinesis"],"dependencies":{"async":"^0.9.0","aws-sdk":"~2.6.0","bunyan":"^1.2.3","kinesalite":"^1.0.2","local-dynamo":"0.0.3","minimist":"^1.1.0","mkdirp":"^0.5.0","underscore":"^1.7.0","vogels":"^0.12.0"},"devDependencies":{"mocha":"^2.2.1","tsd":"^0.6.5","tslint":"^3.5.0","typescript":"^1.8.7"},"gitHead":"224c17d128ed2f4243da5e86142236b7f60bf30e","_id":"kinesis-client-library@0.3.6","_shasum":"56d96fb79b9433d889c7e041800a451a3831fdc3","_from":".","_npmVersion":"3.8.6","_nodeVersion":"6.1.0","_npmUser":{"name":"evansolomon","email":"evan@evanalyze.com"},"dist":{"shasum":"56d96fb79b9433d889c7e041800a451a3831fdc3","tarball":"https://registry.npmjs.org/kinesis-client-library/-/kinesis-client-library-0.3.6.tgz","integrity":"sha512-jHR7N798b+4PE0BNd31o01EWH5MbdsvFkzeMM2Np6kf2RmAqqG3CizKA5lDCx0beHLpoHdnFg21gENIuFhdntQ==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCC510DU6lCQhIVXQBLtZbycZKKsJlHmhdr8trsxKf2zQIhAK1xRbBNdaw9IRZLVVDfSYwhvBLBGki/yamh761FFU/0"}]},"maintainers":[{"name":"evansolomon","email":"evan@evanalyze.com"}],"_npmOperationalInternal":{"host":"packages-12-west.internal.npmjs.com","tmp":"tmp/kinesis-client-library-0.3.6.tgz_1486882869838_0.7307453025132418"}}},"readme":"# Node Kinesis Client Library\n\n[![Build Status](https://travis-ci.org/evansolomon/nodejs-kinesis-client-library.svg?branch=master)](https://travis-ci.org/evansolomon/nodejs-kinesis-client-library)\n\nBased on the AWS [Kinesis Client Library for Java](https://github.com/awslabs/amazon-kinesis-client), reimplemented in Node.js.\n\n* Build Kinesis consumers easily\n* Automatically scale up or down as streams split or merge\n* Allow distributed processing without any extra code\n\nInstall with `npm install kinesis-client-library --save`.\n\nI am using this in production, but it's very new so there's a good chance it will (1) have some bugs and (2) go through a breaking change at some point. Feedback welcome, use with care.\n\n## Why?\n\nI had a stack in Node.js. Working with and deploying a Java app just to consume a stream was too inconvenient, so I made this.\n\n\n## Terminology\n\n* **Consumer**: A single process that is responsible for consuming a single Kinesis shard. Consumers are created and managed by clusters; they should not be created directly directly.\n* **Cluster**: A process that manages consumers. A single cluster can have many consumers (or 1, or 0) that all run on the same machine.  Clusters should be created by the [CLI](#cli).\n* **Network**: All of the consumers processing a single Kinesis stream for a single application. Networks can have many clusters that are run on one or many machines.\n\n\nNetworks are meant to be distributed (though they don't have to be) and will automatically rebalance shards across clusters. Each cluster will try to process an equal number of shards, so it's a good idea to make sure each cluster has equivalent resources (e.g. clusters should have similar memory and CPU available). Networks will automatically pick up new shards as [splits](http://docs.aws.amazon.com/kinesis/latest/APIReference/API_SplitShard.html) or [merges](http://docs.aws.amazon.com/kinesis/latest/APIReference/API_MergeShards.html) happen.\n\nMultiple networks can independently process the same stream as long as the stream has enough capacity. In this case, you should be sure to give each set of processors a unique `table` flag.\n\n\n## Usage\n\nBefore you can do anything with this library, you need to create a Kinesis stream. Everything from this point forward assumes you have an existing stream.\n\n\n### CLI\n\nClusters are designed to be launched from the command line.  The library exposes a `launch-kinesis-cluster` executable.\n\n```\n$ launch-kinesis-cluster --help\nUsage:\n\n--help  (Display this message)\n\nRequired flags:\n--consumer [Path to consumer file]\n--table [DynamoDB table name]\n--stream [Kinesis stream name]\n\nOptional flags:\n--start-at [Starting iterator type] (\"trim_horizon\" or \"latest\", defaults to \"trim_horizon\")\n--capacity.[read|write] [Throughput] (DynamoDB throughput for *new* tables, defaults to 10 for each)\n--aws.[option] [Option value]  (e.g. --aws.region us-west-2)\n--http [port]  (Start HTTP server, port defaults to $PORT)\n--log-level [level] (Logging verbosity, uses Bunyan log levels)\n--dynamo-endpoint (Use a cusotm endpoint for the DynamoDB service)\n--local-dynamo (Whether or not to use a local implementation of DynamoDB, defaults to false)\n--local-dynamo-directory (Directory to store local DB, defaults to temp directory)\n--kinesis-endpoint (Use a custom endpoint for the Kinesis service)\n--local-kinesis (Use a local implementation of Kinesis, defaults to false)\n--local-kinesis-port (Port to access local Kinesis on, defaults to 4567)\n--local-kinesis-no-start (Assume a local Kinesis server is already running, defaults to false)\n--num-records (Maximum number of records to get in each Kinesis query, defaults to the Kinesis maximum of 10000)\n```\n\nNotes:\n* `table` is used as a DynamoDB table name that is unique to the network. If the table doesn't exist yet, it is created.\n* `stream` must match a Kinesis stream that *already exists*.\n* The (optional) HTTP server is primarily meant to be used as a health check.\n* AWS options are based to the [`AWS.Service` constructor](http://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/Service.html), so any other credential strategies (e.g. environment variables, EC2 IAM roles) will be used automatically.\n\n\n### Consumer\n\nConsumers are implemented in JavaScript by calling `AbstractConsumer.extend()` with an object that implements some/all of these methods:\n\n* `processRecords`: Accepts an array of [Record](http://docs.aws.amazon.com/kinesis/latest/APIReference/API_Record.html) objects (`Record.Data` will be a `Buffer` object) and a callback. Pass `true` as the second argument to the callback when you want to save a checkpoint — i.e. when you have processed a chunk of data.\n* `processResponse`: Accepts a full response from Kinesis' [GetRecords API](http://docs.aws.amazon.com/kinesis/latest/APIReference/API_GetRecords.html) and a callback. Pass `true` as the second argument to the callback when you want to save a checkpoint — i.e. when you have processed a chunk of data.\n* `initialize`: Called when a consumer is spawned, before any records are processed. Accepts a callback that must be called to start record processing.\n* `shutdown`: Called when a consumer is about to exit. Accepts a callback that must be called to complete shutdown; if the callback is not called without 30 seconds the process exits anyway.\n\nA consumer MUST implement either `processRecords` or `processResponse`.\n\n#### Example consumer implementation\n\nThis consumer uploads records to S3 in 50 megabyte batches.\n\n```js\n// AWS config skipped for brevity\nvar s3 = new require('aws-sdk').S3()\nvar kcl = require('kinesis-client-library')\n\nvar newlineBuffer = new Buffer('\\n')\n\nkcl.AbstractConsumer.extend({\n  // create places to hold some data about the consumer\n  initialize: function (done) {\n    this.cachedRecords = []\n    this.cachedRecordsSize = 0\n    // This MUST be called or processing will never start\n    // That is really really really bad\n    done()\n  },\n\n  processRecords: function (records, done) {\n    // Put each record into our list of cached records (separated by newlines) and update the size\n    records.forEach(function (record) {\n      this.cachedRecords.push(record.Data)\n      this.cachedRecords.push(newlineBuffer)\n      this.cachedRecordsSize += (record.Data.length + newlineBuffer.length)\n    }.bind(this))\n\n    // not very good for performance\n    var shouldCheckpoint = this.cachedRecordsSize > 50000000\n\n    // Get more records, but not save a checkpoint\n    if (! shouldCheckpoint) return done()\n\n    // Upload the records to S3\n    s3.putObject({\n      Bucket: 'my-bucket-name',\n      Key: 'path/to/records/' + Date.now(),\n      Body: Buffer.concat(this.cachedRecords)\n    }, function (err)  {\n      if (err) return done(err)\n\n      this.cachedRecords = []\n      this.cachedRecordsSize = 0\n\n      // Pass `true` to checkpoint the latest record we've received\n      done(null, true)\n    }.bind(this))\n  }\n})\n```\n\n#### Example consumer launch\n\nAssume the code above is in `lib/consumer.js` and you've got a package with `kinesis-client-library` declared as a dependency.\n\nFor convenience, we'll assume your AWS credentials are defined as [environment variables](http://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/EnvironmentCredentials.html). Using the command line, you could launch a cluster like this.\n\n```\nlaunch-kinesis-cluster \\\n  --consumer lib/consumer.js \\\n  --table MyKinesisConsumerApp \\\n  --stream MyKinesisStreamName \\\n  --aws.region us-east-1\n```\n","maintainers":[{"name":"evansolomon","email":"evan@evanalyze.com"}],"time":{"modified":"2022-06-19T08:46:48.457Z","created":"2014-12-15T01:39:58.479Z","0.1.0":"2014-12-15T01:39:58.479Z","0.1.1":"2014-12-16T18:19:34.231Z","0.2.0":"2015-01-28T19:19:14.887Z","0.2.1":"2015-02-12T01:17:51.506Z","0.2.2":"2015-02-14T07:04:22.904Z","0.2.3":"2015-03-02T18:31:06.256Z","0.2.4":"2015-03-10T02:22:02.444Z","0.2.5":"2015-03-31T01:15:47.526Z","0.2.6":"2015-04-22T17:34:47.984Z","0.2.7":"2015-06-17T19:26:32.880Z","0.3.0":"2015-08-05T01:02:24.889Z","0.3.1":"2015-08-19T05:57:29.820Z","0.3.2":"2015-08-19T22:13:34.430Z","0.3.3":"2015-08-28T04:46:22.252Z","0.3.4":"2015-08-28T05:55:18.387Z","0.3.5":"2016-03-09T02:21:58.953Z","0.3.6":"2017-02-12T07:01:10.061Z"},"author":{"name":"Evan Solomon"},"license":"MIT","readmeFilename":"README.md","homepage":"https://github.com/evansolomon/nodejs-kinesis-client-library","keywords":["aws","kinesis"],"repository":{"type":"git","url":"git://github.com/evansolomon/nodejs-kinesis-client-library.git"},"bugs":{"url":"https://github.com/evansolomon/nodejs-kinesis-client-library/issues"},"users":{"goliatone":true}}