{"_id":"prozess","_rev":"57-bfcad93e27244bb88550be35b146461b","name":"prozess","description":"Prozess is a kafka library for Node.js","dist-tags":{"latest":"0.7.3"},"versions":{"0.1.0":{"name":"prozess","description":"Prozess is a kafka library for Node.js","keywords":["kafka","producer","consumer"],"version":"0.1.0","bugs":{"url":"https://github.com/cainus/Prozess/issues"},"scripts":{"test":"make test"},"maintainers":[{"name":"cainus","email":"gregg@caines.ca"}],"dependencies":{"underscore":"1.3.3","buffermaker":"0.0.8","binary":"0.3.0","crc32":"0.2.2","bignum":"0.5.1"},"devDependencies":{"mockery":"1.1.2","hottap":"1.0.1","mocha":"1.3.0","should":"1.1.0"},"_id":"prozess@0.1.0","dist":{"shasum":"9929e521845713e889754402db825bf6f8128d7a","tarball":"https://registry.npmjs.org/prozess/-/prozess-0.1.0.tgz","integrity":"sha512-020taO8j6H2Ar4ve12uQhK37TWK19FqNoumjhAOwTXHUXy+fxerRl10dqmha7bo6dqU83O/Y5aul77dmtRVRfQ==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIBfX9IQ4L/CEwDgpcOyQEJiQbUep3zZpiUUbikgb18KUAiEAjfFkefzQPgAJS9b2c2zRwM3eLu5NGmXUNJYOxufQcNU="}]}},"0.1.1":{"name":"prozess","description":"Prozess is a kafka library for Node.js","keywords":["kafka","producer","consumer"],"version":"0.1.1","bugs":{"url":"https://github.com/cainus/Prozess/issues"},"scripts":{"test":"make test"},"maintainers":[{"name":"cainus","email":"gregg@caines.ca"}],"dependencies":{"underscore":"1.3.3","buffermaker":"0.0.8","binary":"0.3.0","crc32":"0.2.2","bignum":"0.5.1"},"devDependencies":{"mockery":"1.1.2","hottap":"1.0.1","mocha":"1.3.0","should":"1.1.0"},"_id":"prozess@0.1.1","dist":{"shasum":"9bc291da9fe3233b7f139d4ca77b589e3f7a3b2a","tarball":"https://registry.npmjs.org/prozess/-/prozess-0.1.1.tgz","integrity":"sha512-cehkbnqUmRVbi8L77JdI2aADvRCQzDm330JagqXjypeOYLR+RzQu+oL1MZpho7HPiFakT9FYaRP8Ht5Q+/GacA==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIFgSS4hf3rglobQDptSK2uG20q/q7B6rKWUVW1u7GBGlAiBJTK2QAzt5KdJGmpAfTrJu/3yuTLBC/sKD2UJJLFYrtg=="}]}},"0.1.2":{"name":"prozess","description":"Prozess is a kafka library for Node.js","keywords":["kafka","producer","consumer"],"version":"0.1.2","bugs":{"url":"https://github.com/cainus/Prozess/issues"},"scripts":{"test":"make test"},"maintainers":[{"name":"cainus","email":"gregg@caines.ca"}],"dependencies":{"underscore":"1.3.3","buffermaker":"0.0.8","binary":"0.3.0","crc32":"0.2.2","bignum":"0.5.1"},"devDependencies":{"mockery":"1.1.2","hottap":"1.0.1","mocha":"1.3.0","should":"1.1.0"},"_id":"prozess@0.1.2","dist":{"shasum":"4df9108aefd350f147ab47ba43529703e257a0a0","tarball":"https://registry.npmjs.org/prozess/-/prozess-0.1.2.tgz","integrity":"sha512-BvTY2hgqPbortDZOL/qjSC/vd4lxHJP+Eq6joztLbi6QoOKE/sh16r3keKGRuafoO0e+x2h27YHpoZATM77vaQ==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIH6SHHO7WkAmRmBloxMUbxhhyoNierLyDeueFW2wn95mAiEAhCAwS6HyacNmZBHCirqqOzO2X0r8TDzMwb6N45VS3FQ="}]}},"0.2.0":{"name":"prozess","description":"Prozess is a kafka library for Node.js","keywords":["kafka","producer","consumer"],"version":"0.2.0","bugs":{"url":"https://github.com/cainus/Prozess/issues"},"scripts":{"test":"make test"},"maintainers":[{"name":"cainus","email":"gregg@caines.ca"}],"dependencies":{"underscore":"1.3.3","buffermaker":"0.0.8","binary":"0.3.0","crc32":"0.2.2","bignum":"0.5.1"},"devDependencies":{"mockery":"1.1.2","hottap":"1.0.1","mocha":"1.3.0","should":"1.1.0"},"_id":"prozess@0.2.0","dist":{"shasum":"6c1d095d4440281e4312094f42314c23de86de09","tarball":"https://registry.npmjs.org/prozess/-/prozess-0.2.0.tgz","integrity":"sha512-qDpo6t2AlE2yjudWKQYW7PmREFIiCT5MT8uGFWXpvY4t8BRP+gRKAFH8cfFaV/PlZwh44bVYSzpzIfL2vhcKqw==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIAcaDF/MUs6J0wBAOeUmif/Y/rR/o9l0iduRNe/jBMMpAiAie7ASIVZ7CKATCwfb7IgcVSLiDOnx+KUBI/EEsLbLHg=="}]}},"0.2.1":{"name":"prozess","description":"Prozess is a kafka library for Node.js","keywords":["kafka","producer","consumer"],"version":"0.2.1","bugs":{"url":"https://github.com/cainus/Prozess/issues"},"scripts":{"test":"make test"},"maintainers":[{"name":"cainus","email":"gregg@caines.ca"}],"dependencies":{"underscore":"1.3.3","buffermaker":"0.0.8","binary":"0.3.0","crc32":"0.2.2","bignum":"0.5.1"},"devDependencies":{"mockery":"1.1.2","hottap":"1.0.1","mocha":"1.3.0","should":"1.1.0"},"_id":"prozess@0.2.1","dist":{"shasum":"30a6db37c3214aebfe48dd589b79bd22231833f2","tarball":"https://registry.npmjs.org/prozess/-/prozess-0.2.1.tgz","integrity":"sha512-AUcEi37WlGlCPQsDb8ewUoPHOi+kVu5Agi8tNLWg4UyKhbbHUOSB3QzHEcLLUWvfxskV/VNo1vVUDskUzTFw4w==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQCrBnIBe9pKwIv0EVLOOw/HpksIMz8SZ+mj5UKpFXovrAIgbE4tW1UB5l9goF8Rh5/yk5hHikFxShS3AMIsxD0HiNY="}]}},"0.2.2":{"name":"prozess","description":"Prozess is a kafka library for Node.js","keywords":["kafka","producer","consumer"],"version":"0.2.2","bugs":{"url":"https://github.com/cainus/Prozess/issues"},"scripts":{"test":"make test"},"maintainers":[{"name":"cainus","email":"gregg@caines.ca"}],"dependencies":{"underscore":"1.3.3","buffermaker":"0.0.8","binary":"0.3.0","crc32":"0.2.2","bignum":"0.5.1"},"devDependencies":{"mockery":"1.1.2","hottap":"1.0.1","mocha":"1.3.0","should":"1.1.0"},"_id":"prozess@0.2.2","dist":{"shasum":"c6f6f07aca05f1f6444bfc4a9c3500e8dc39d083","tarball":"https://registry.npmjs.org/prozess/-/prozess-0.2.2.tgz","integrity":"sha512-D43KUeo2QkPmDjZhXcEp8XbZM0dNDpgKJsTShpQ3beX2CTCcEUW++rwukYhdxqkeu+o0qpTxiBXQ+gKBW2774A==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIC+LihKttKP7egWGuw7emAN1zo3Bq06+4xeHh/dKZyNGAiEApDt8JX5uYY/aZPg58Ni3m0sydl2bqyeJlYA2XNgbQt0="}]}},"0.2.3":{"name":"prozess","description":"Prozess is a kafka library for Node.js","keywords":["kafka","producer","consumer"],"version":"0.2.3","bugs":{"url":"https://github.com/cainus/Prozess/issues"},"scripts":{"test":"make test"},"maintainers":[{"name":"cainus","email":"gregg@caines.ca"}],"contributors":[{"name":"Christoph Tavan"}],"dependencies":{"underscore":"1.3.3","buffermaker":"0.0.8","binary":"0.3.0","crc32":"0.2.2","bignum":"0.5.1"},"devDependencies":{"mockery":"1.1.2","hottap":"1.0.1","mocha":"1.3.0","should":"1.1.0"},"_id":"prozess@0.2.3","dist":{"shasum":"0a2ae27e3f7c421aa8f94f99bdccff4eafaeb41e","tarball":"https://registry.npmjs.org/prozess/-/prozess-0.2.3.tgz","integrity":"sha512-1sWTQFLLde7ViNgNdcSJszQxCzPqjI7tPdHcmKvWK67x+/G6gbHp7d/o9M4xcP2mLjyPK/8af+JlO8pukifNJQ==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCQ51iXuTcXD0MD0+d3hMkBTpTU8SgFVwAtPo23o7+lpwIhAPw7IcvBXnv01LCVSv2F6CAaxiWIwnpSINglB9zZTm1T"}]}},"0.3.0":{"name":"prozess","description":"Prozess is a kafka library for Node.js","keywords":["kafka","producer","consumer"],"version":"0.3.0","bugs":{"url":"https://github.com/cainus/Prozess/issues"},"scripts":{"test":"make test"},"maintainers":[{"name":"cainus","email":"gregg@caines.ca"}],"contributors":[{"name":"Christoph Tavan"}],"dependencies":{"underscore":"1.3.3","buffermaker":"0.0.8","binary":"0.3.0","crc32":"0.2.2","bignum":"0.5.4"},"devDependencies":{"mockery":"1.1.2","hottap":"1.0.1","mocha":"1.3.0","should":"1.1.0","sinon":"1.5.2"},"_id":"prozess@0.3.0","dist":{"shasum":"58e0bbaf465064c29c2e9b533651a5cfbdc8eb21","tarball":"https://registry.npmjs.org/prozess/-/prozess-0.3.0.tgz","integrity":"sha512-AkutiY9ShSKpGQv7XpLRrIE7RLqCb/0iMrnBiZWHHlJVad78tePEARfctS75Ayrds3MIMSEYKaNTn1IkJ5WHGg==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQCNhAenHfP/HbynrAO7lCR89A2TovjurF/LUl/OGaFvoAIgNWF610nn5SvjT27V90y55m1CDJgYLEil1oAZ6BgDtKI="}]},"_npmVersion":"1.2.0","_npmUser":{"name":"cainus","email":"gregg@caines.ca"}},"0.3.1":{"name":"prozess","description":"Prozess is a kafka library for Node.js","keywords":["kafka","producer","consumer"],"version":"0.3.1","bugs":{"url":"https://github.com/cainus/Prozess/issues"},"scripts":{"test":"make test"},"maintainers":[{"name":"cainus","email":"gregg@caines.ca"}],"contributors":[{"name":"Christoph Tavan"}],"dependencies":{"underscore":"1.3.3","buffermaker":"0.0.8","binary":"0.3.0","crc32":"0.2.2","bignum":"0.5.4"},"devDependencies":{"mockery":"1.1.2","hottap":"1.0.1","mocha":"1.3.0","should":"1.1.0","sinon":"1.5.2"},"_id":"prozess@0.3.1","dist":{"shasum":"366fc0f74f02b7aac9f030efa467db6c7495e772","tarball":"https://registry.npmjs.org/prozess/-/prozess-0.3.1.tgz","integrity":"sha512-4a5OtbAxN0hsyWg8yrOBusHnyCG39ayX/U4ZHCg4+BTspKaSKCwWcnDyylvpb6QVUAwUpLh8/DHGcwH8WOLzeg==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDUhsWFbPyXnHTKQcFgI9eKKgddd82QNZDFgQpxzh++jAIgQzPZFHe0pgMK5JHc8vYiOCPT/BaBCKJrO5rnI62PGUk="}]},"_npmVersion":"1.2.0","_npmUser":{"name":"cainus","email":"gregg@caines.ca"}},"0.3.2":{"name":"prozess","description":"Prozess is a kafka library for Node.js","keywords":["kafka","producer","consumer"],"version":"0.3.2","bugs":{"url":"https://github.com/cainus/Prozess/issues"},"scripts":{"test":"make test-coveralls"},"maintainers":[{"name":"cainus","email":"gregg@caines.ca"}],"contributors":[{"name":"Christoph Tavan"}],"dependencies":{"underscore":"1.3.3","buffermaker":"0.0.9","binary":"0.3.0","crc32":"0.2.2","bignum":"0.5.4"},"devDependencies":{"jscoverage":"0.3.6","coveralls":"1.1.2","mockery":"1.1.2","hottap":"1.0.1","mocha":"1.3.0","should":"1.1.0","sinon":"1.5.2"},"_id":"prozess@0.3.2","dist":{"shasum":"1b6660f565f6bc1145104d72a384a10bfa0400bc","tarball":"https://registry.npmjs.org/prozess/-/prozess-0.3.2.tgz","integrity":"sha512-mO2LP0ApZt5F6gbd/rJF4BwEmRbt8LoimclLpQrTW69NSxYX7MDn1dz3NbaUJDchVv6FQK29RrQdnlYeJ/EuiA==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQDZpfb8vzwJQpwuqroCEE1WhfVcW2oTaICQ+JoWA88qBwIhAM+2ThKXH6Gk7DBstTFeT/0CXEVjbaWMgm9W4En3k38O"}]},"_npmVersion":"1.1.62","_npmUser":{"name":"cainus","email":"gregg@caines.ca"}},"0.3.3":{"name":"prozess","description":"Prozess is a kafka library for Node.js","keywords":["kafka","producer","consumer"],"version":"0.3.3","bugs":{"url":"https://github.com/cainus/Prozess/issues"},"scripts":{"test":"make test-coveralls"},"maintainers":[{"name":"cainus","email":"gregg@caines.ca"}],"contributors":[{"name":"Christoph Tavan"}],"dependencies":{"underscore":"1.3.3","buffermaker":"0.0.9","binary":"0.3.0","crc32":"0.2.2","bignum":"0.5.4"},"devDependencies":{"jscoverage":"0.3.6","coveralls":"1.1.2","mockery":"1.1.2","hottap":"1.0.1","mocha":"1.3.0","should":"1.1.0","sinon":"1.5.2"},"_id":"prozess@0.3.3","dist":{"shasum":"6a34c569250917030a78b7ff050ff70c71587352","tarball":"https://registry.npmjs.org/prozess/-/prozess-0.3.3.tgz","integrity":"sha512-B8FPAxaRJt+oW7r1Fgl1XJbJF9LxtqH3SD+YNQjErK8Zvy+qMEXp6ETiMOW2l0L6mTqrKysZkkE4tH9g1kFyKA==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCHhsTRFWWc76FpQpMX8oIc0mZ9PCm9g2WyUr5531WPsQIhAORlv2rp6UbSuB122kGHJBfga3Zx9PTRx/OWVWWe9ocH"}]},"_npmVersion":"1.2.0","_npmUser":{"name":"cainus","email":"gregg@caines.ca"}},"0.3.4":{"name":"prozess","description":"Prozess is a kafka library for Node.js","keywords":["kafka","producer","consumer"],"version":"0.3.4","bugs":{"url":"https://github.com/cainus/Prozess/issues"},"scripts":{"test":"make test-coveralls"},"maintainers":[{"name":"cainus","email":"gregg@caines.ca"}],"contributors":[{"name":"Christoph Tavan"}],"dependencies":{"underscore":"1.3.3","buffermaker":"0.0.9","binary":"0.3.0","crc32":"0.2.2","buffer-crc32":"0.2.1","bignum":"0.5.4"},"devDependencies":{"jscoverage":"0.3.6","coveralls":"1.1.2","mockery":"1.1.2","hottap":"1.0.1","mocha":"1.3.0","should":"1.1.0","sinon":"1.5.2"},"_id":"prozess@0.3.4","dist":{"shasum":"1a315528a03b9b05e85986d376cde9c4ac4c60e9","tarball":"https://registry.npmjs.org/prozess/-/prozess-0.3.4.tgz","integrity":"sha512-xJrTc6PRlWbQFOeVLhQ8/TzH6WwKgpM3m1Ue9leNo2MqMes+KXLSo835KhKbqdf5h6nd9diIYDJeo0Q1P9T/6Q==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCYSUnqo0gCHnTrIGjUpDqVDyzEwH27jm7uQMREND1YFgIhAILGegGZF/7TmE3ro42/vn+vpyrWkQqzXXONSVA02MPr"}]},"_npmVersion":"1.1.62","_npmUser":{"name":"cainus","email":"gregg@caines.ca"}},"0.3.5":{"name":"prozess","description":"Prozess is a kafka library for Node.js","keywords":["kafka","producer","consumer"],"version":"0.3.5","bugs":{"url":"https://github.com/cainus/Prozess/issues"},"scripts":{"test":"make test-coveralls"},"maintainers":[{"name":"cainus","email":"gregg@caines.ca"}],"contributors":[{"name":"Christoph Tavan"}],"dependencies":{"underscore":"1.3.3","buffermaker":"0.0.9","binary":"0.3.0","crc32":"0.2.2","buffer-crc32":"0.2.1","bignum":"0.6.0"},"devDependencies":{"jscoverage":"0.3.6","coveralls":"1.1.2","mockery":"1.1.2","hottap":"1.0.1","mocha":"1.3.0","should":"1.1.0","sinon":"1.5.2"},"_id":"prozess@0.3.5","dist":{"shasum":"aa906132d6fca7e7446f0d66018bf357250d76c8","tarball":"https://registry.npmjs.org/prozess/-/prozess-0.3.5.tgz","integrity":"sha512-jDNYMcGGY/Q3ZBqhIBRnI08Q2UyTx1G7InPzFKFEhDw0AqGvJFo4K3qODLSXL5IUaKQpqFkHmeSj7EEGknXGrw==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQCsiEuSsRev/sGLN9pZxsKibaoSCuo8JGB0LrnyuIfwnQIgQphdQmr63qQSw6CRrYjkl/y6ymbEJyV5qnmZ9SEcR6g="}]},"_npmVersion":"1.1.62","_npmUser":{"name":"cainus","email":"gregg@caines.ca"}},"0.3.6":{"name":"prozess","description":"Prozess is a kafka library for Node.js","keywords":["kafka","producer","consumer"],"version":"0.3.6","bugs":{"url":"https://github.com/cainus/Prozess/issues"},"scripts":{"test":"make test-coveralls"},"maintainers":[{"name":"cainus","email":"gregg@caines.ca"}],"contributors":[{"name":"Christoph Tavan"}],"dependencies":{"underscore":"1.3.3","buffermaker":"0.0.10","binary":"0.3.0","crc32":"0.2.2","buffer-crc32":"0.2.1","bignum":"0.6.0"},"devDependencies":{"jscoverage":"0.3.6","coveralls":"1.1.2","mockery":"1.1.2","hottap":"1.0.1","mocha":"1.3.0","should":"1.1.0","sinon":"1.5.2"},"_id":"prozess@0.3.6","dist":{"shasum":"bc23379f148bf1870c2e9dcf58c23dcfe9caf457","tarball":"https://registry.npmjs.org/prozess/-/prozess-0.3.6.tgz","integrity":"sha512-6OMvttRXUcs24+cXPkGdWo+mr4DTU2vEwZS4DYgtl978e3OFCogJwA76con0bv8xPB4TbUyALJpuUHMz8sa1oA==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIGu6Tmzj1UWJVzjPjHbpbU7u9zh0IELGSa4iZqNeAx+BAiEAnjupUiZmWxDbpi3QfGSFl7jekSZI7MKIRYbC29kCdEg="}]},"_npmVersion":"1.2.0","_npmUser":{"name":"cainus","email":"gregg@caines.ca"}},"0.3.7":{"name":"prozess","description":"Prozess is a kafka library for Node.js","keywords":["kafka","producer","consumer"],"version":"0.3.7","bugs":{"url":"https://github.com/cainus/Prozess/issues"},"scripts":{"test":"make test-coveralls"},"maintainers":[{"name":"cainus","email":"gregg@caines.ca"}],"contributors":[{"name":"Christoph Tavan"},{"name":"Devon Crouse"}],"dependencies":{"underscore":"1.3.3","buffermaker":"0.0.10","binary":"0.3.0","crc32":"0.2.2","buffer-crc32":"0.2.1","bignum":"0.6.0"},"devDependencies":{"jscoverage":"0.3.6","coveralls":"1.1.2","mockery":"1.1.2","hottap":"1.0.1","mocha":"1.3.0","should":"1.1.0","sinon":"1.5.2"},"_id":"prozess@0.3.7","dist":{"shasum":"d4271965c0b5d89de19ecdbe8c14886e5b0f9190","tarball":"https://registry.npmjs.org/prozess/-/prozess-0.3.7.tgz","integrity":"sha512-CmhtCRE/ISjguOpM3MnkKNgtjSRth/aRXwMPO+q18IfSc7FTsNmzX+yCT02N/8fv/Im7PYMeXzlN8VJ/0eQvzQ==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCS8UlVBhJxJ0CssvX8qiJAT4OdDx+iEPC9gQv2G3BORAIhAMq8peROyMXzUOLRKqoUQpzBIsIod2Gr4ECFm+ChoThF"}]},"_npmVersion":"1.2.0","_npmUser":{"name":"cainus","email":"gregg@caines.ca"}},"0.4.0":{"name":"prozess","description":"Prozess is a kafka library for Node.js","keywords":["kafka","producer","consumer"],"version":"0.4.0","bugs":{"url":"https://github.com/cainus/Prozess/issues"},"scripts":{"test":"make test-coveralls"},"maintainers":[{"name":"cainus","email":"gregg@caines.ca"}],"contributors":[{"name":"Christoph Tavan"},{"name":"Devon Crouse"}],"dependencies":{"underscore":"1.3.3","buffermaker":"0.0.10","binary":"0.3.0","crc32":"0.2.2","buffer-crc32":"0.2.1","bignum":"0.6.0"},"devDependencies":{"jscoverage":"0.3.6","coveralls":"1.1.2","mockery":"1.1.2","hottap":"1.0.1","mocha":"1.3.0","should":"1.1.0","sinon":"1.5.2"},"_id":"prozess@0.4.0","dist":{"shasum":"b8fd2dde6b09e9d4e1445b8e8e6764076d11ce42","tarball":"https://registry.npmjs.org/prozess/-/prozess-0.4.0.tgz","integrity":"sha512-7fov4UxSzqeOcWv4NfSi21/ii44RicnSPaq8cqhpSX8uNvSh74r+/64+OL79H18ook/owfzeLCqTx9N9vmKa7w==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQCOy7gEbe8KeRSDJsd9Zjr8TR5iDNtz/Duu3yl9VyWclgIgC8c4dRzyMpvjQYAaEapt2sIf8SvUzLdPlvCtQn1nry8="}]},"_npmVersion":"1.2.0","_npmUser":{"name":"cainus","email":"gregg@caines.ca"}},"0.5.0":{"name":"prozess","description":"Prozess is a kafka library for Node.js","keywords":["kafka","producer","consumer"],"version":"0.5.0","bugs":{"url":"https://github.com/cainus/Prozess/issues"},"scripts":{"test":"make test-coveralls"},"maintainers":[{"name":"cainus","email":"gregg@caines.ca"}],"contributors":[{"name":"Christoph Tavan"},{"name":"Devon Crouse"}],"dependencies":{"underscore":"1.3.3","buffermaker":"0.0.10","binary":"0.3.0","crc32":"0.2.2","buffer-crc32":"0.2.1","bignum":"0.6.0"},"devDependencies":{"jscoverage":"0.3.6","coveralls":"1.1.2","mockery":"1.1.2","hottap":"1.0.1","mocha":"1.3.0","should":"1.1.0","sinon":"1.5.2"},"_id":"prozess@0.5.0","dist":{"shasum":"43efb0aa42da2a1680e1f0d3f3adb13882f0beda","tarball":"https://registry.npmjs.org/prozess/-/prozess-0.5.0.tgz","integrity":"sha512-y2sWcXsuFvjn7qy2pMjm10RhgiRAzGxsJxw7qZa8Knv7DG3Hl9qHciaB1RuKqs5lKl4niaE/IeCFouFo8CPiWA==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEMCH1128XxJyUCTGWarhzum/waptpHC7hkcRqNvDKHeO9YCIEtzwZC5oxE7ehLjxFwhc07IXNyotjm97sDoWDgXdVkB"}]},"_npmVersion":"1.2.0","_npmUser":{"name":"cainus","email":"gregg@caines.ca"}},"0.6.0":{"name":"prozess","description":"Prozess is a kafka library for Node.js","keywords":["kafka","producer","consumer"],"version":"0.6.0","bugs":{"url":"https://github.com/cainus/Prozess/issues"},"scripts":{"test":"make test-coveralls"},"maintainers":[{"name":"cainus","email":"gregg@caines.ca"}],"contributors":[{"name":"Christoph Tavan"},{"name":"Devon Crouse"}],"dependencies":{"underscore":"1.3.3","buffermaker":"0.0.10","binary":"0.3.0","crc32":"0.2.2","buffer-crc32":"0.2.1","bignum":"0.6.0"},"devDependencies":{"jscoverage":"0.3.6","coveralls":"1.1.2","mockery":"1.1.2","hottap":"1.0.1","mocha":"1.3.0","should":"1.1.0","sinon":"1.5.2"},"_id":"prozess@0.6.0","dist":{"shasum":"d4a606ffa719d6b22dfd28230c40fd2396d45a7e","tarball":"https://registry.npmjs.org/prozess/-/prozess-0.6.0.tgz","integrity":"sha512-VBNJRUCp1zi7LBytVEtZMlltYcv0yTDnC/NnC6pE18lAeOfM4lHoEyiFMEBD3tDujz4qw86preYR59G5s8y2eQ==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIEt77x4tfbRAeBnEJ7Nz7gAcTolyszqXvIC+GDlK6BaRAiEAiHYoOd/LhBGObV7dN8TutGmYMlUzmJiRE1GSYDumZnM="}]},"_npmVersion":"1.2.0","_npmUser":{"name":"cainus","email":"gregg@caines.ca"}},"0.6.1":{"name":"prozess","description":"Prozess is a kafka library for Node.js","keywords":["kafka","producer","consumer"],"version":"0.6.1","bugs":{"url":"https://github.com/cainus/Prozess/issues"},"scripts":{"test":"make test-coveralls"},"maintainers":[{"name":"cainus","email":"gregg@caines.ca"}],"contributors":[{"name":"Christoph Tavan"},{"name":"Devon Crouse"},{"name":"Mithun Satheesh","email":"mithunsatish@gmail.com","url":"http://www.linkedin.com/pub/mithun-satheesh/28/89b/a56"}],"dependencies":{"underscore":"1.3.3","buffermaker":"0.0.11","binary":"0.3.0","crc32":"0.2.2","buffer-crc32":"0.2.1","bignum":"0.6.1"},"devDependencies":{"jscoverage":"0.3.6","coveralls":"1.1.2","mockery":"1.1.2","hottap":"1.0.1","mocha":"1.3.0","should":"1.1.0","sinon":"1.5.2"},"main":"index.js","directories":{"test":"test"},"repository":{"type":"git","url":"git://github.com/cainus/Prozess.git"},"author":"","license":"BSD","_id":"prozess@0.6.1","dist":{"shasum":"58f66029c035351db1ffb93178f8d407d789d3a0","tarball":"https://registry.npmjs.org/prozess/-/prozess-0.6.1.tgz","integrity":"sha512-dIjIRUralrE/7Mf19XH4wiuUCJ1310Nx0ubY703Uj1VjtHgD7raQxEMG20FG25yhl5ZDD5TbzXgywrFwKbbNQw==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQC5Glu7N7q9AvDfwnUsVl4nA7Lx4lSARwH6Rxm5GNny6wIhALNiMTy1+0/nH/3kfXTqwztanSq/Fq/vb514askHog3C"}]},"_from":".","_npmVersion":"1.3.5","_npmUser":{"name":"cainus","email":"gregg@caines.ca"}},"0.6.2":{"name":"prozess","description":"Prozess is a kafka library for Node.js","keywords":["kafka","producer","consumer"],"version":"0.6.2","bugs":{"url":"https://github.com/cainus/Prozess/issues"},"scripts":{"test":"make test-coveralls"},"maintainers":[{"name":"cainus","email":"gregg@caines.ca"}],"contributors":[{"name":"Christoph Tavan"},{"name":"Devon Crouse"},{"name":"Mithun Satheesh","email":"mithunsatish@gmail.com","url":"http://www.linkedin.com/pub/mithun-satheesh/28/89b/a56"}],"dependencies":{"underscore":"1.3.3","buffermaker":"1.0.0","binary":"0.3.0","crc32":"0.2.2","buffer-crc32":"0.2.1","bignum":"0.6.1"},"devDependencies":{"jscoverage":"0.3.6","coveralls":"1.1.2","mockery":"1.1.2","hottap":"1.0.1","mocha":"1.3.0","should":"1.1.0","sinon":"1.5.2"},"main":"index.js","directories":{"test":"test"},"repository":{"type":"git","url":"git://github.com/cainus/Prozess.git"},"engines":{"node":">=0.8.0"},"author":"","license":"BSD","_id":"prozess@0.6.2","dist":{"shasum":"3850b9426f2961022f6b7dacd3636bda84df70c3","tarball":"https://registry.npmjs.org/prozess/-/prozess-0.6.2.tgz","integrity":"sha512-OII7FD12xolFDFVUP4Xg/bx7u7hgnYqPBVmD52xpB7x2mlhQFmxFp+7ivC5jUFGEv0uKApk9ImZB5NKUaRhacg==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIBdaE0DvLLewAnc0p4+2NVoSlE/SgD4GP3g7yTNXt0RDAiEA5TnzxZlKkbms1dVAyts7Ta6mcGqSG/8JfCLZjfrj7BQ="}]},"_npmVersion":"1.2.0","_npmUser":{"name":"cainus","email":"gregg@caines.ca"}},"0.6.3":{"name":"prozess","description":"Prozess is a kafka library for Node.js","keywords":["kafka","producer","consumer"],"version":"0.6.3","bugs":{"url":"https://github.com/cainus/Prozess/issues"},"scripts":{"test":"make test-coveralls"},"maintainers":[{"name":"cainus","email":"gregg@caines.ca"}],"contributors":[{"name":"Christoph Tavan"},{"name":"Devon Crouse"},{"name":"Mithun Satheesh","email":"mithunsatish@gmail.com","url":"http://www.linkedin.com/pub/mithun-satheesh/28/89b/a56"}],"dependencies":{"underscore":"1.3.3","buffermaker":"1.0.0","binary":"0.3.0","crc32":"0.2.2","buffer-crc32":"0.2.1","bignum":"0.6.2"},"devDependencies":{"jscoverage":"0.3.6","coveralls":"1.1.2","mockery":"1.1.2","hottap":"1.0.1","mocha":"1.3.0","should":"1.1.0","sinon":"1.5.2"},"main":"index.js","directories":{"test":"test"},"repository":{"type":"git","url":"git://github.com/cainus/Prozess.git"},"engines":{"node":">=0.8.0"},"author":"","license":"BSD","_id":"prozess@0.6.3","dist":{"shasum":"b728fdb741cc2d4e76c67eccf0b60de1cb6c140d","tarball":"https://registry.npmjs.org/prozess/-/prozess-0.6.3.tgz","integrity":"sha512-zKdMZaPJtCb49u65tvfUJ1zfzE1EV8v2DTifZ2vMzrMQxc+Qsd+fH7WxH0d+un21ewQkIpjyA2AjhUb7V7QzGA==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQD1qRocs31Km78gKff6WtaozobrWFtxY7+r0xCq4rSxtwIhAPXxltyYL6bMwEPY+R0fu09KzOTS9Dq5lP1rmJtz6R13"}]},"_npmVersion":"1.2.0","_npmUser":{"name":"cainus","email":"gregg@caines.ca"}},"0.6.4":{"name":"prozess","description":"Prozess is a kafka library for Node.js","keywords":["kafka","producer","consumer"],"version":"0.6.4","bugs":{"url":"https://github.com/cainus/Prozess/issues"},"scripts":{"test":"make test-coveralls"},"maintainers":[{"name":"cainus","email":"gregg@caines.ca"}],"contributors":[{"name":"Christoph Tavan"},{"name":"Devon Crouse"},{"name":"Mithun Satheesh","email":"mithunsatish@gmail.com","url":"http://www.linkedin.com/pub/mithun-satheesh/28/89b/a56"}],"dependencies":{"underscore":"1.3.3","buffermaker":"1.0.0","binary":"0.3.0","crc32":"0.2.2","buffer-crc32":"0.2.1","bignum":"0.6.2"},"devDependencies":{"jscoverage":"0.3.6","coveralls":"1.1.2","mockery":"1.1.2","hottap":"1.0.1","mocha":"1.3.0","should":"1.1.0","sinon":"1.5.2"},"main":"index.js","directories":{"test":"test"},"repository":{"type":"git","url":"git://github.com/cainus/Prozess.git"},"engines":{"node":">=0.8.0"},"author":"","license":"BSD","_id":"prozess@0.6.4","dist":{"shasum":"b3ac9245eec348ec4de295509a4fe3d842b18bc4","tarball":"https://registry.npmjs.org/prozess/-/prozess-0.6.4.tgz","integrity":"sha512-XQgHJCcemOfjksiU9sx/PDip5ox+zcq3STNTRyeJBOV+LxxJn6i7vvJtSmcjlhDQImnTgviEV8161xLjdnAjgw==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIH2lzfjjHl+zBTGXGqBflNrg2p0ilKDmzccRsQn0IFkRAiBrX/mFjdeUXNtKMGAtWPAERPbLPYS7tEeCcec4j0pjdQ=="}]},"_npmVersion":"1.2.0","_npmUser":{"name":"cainus","email":"gregg@caines.ca"}},"0.7.0":{"name":"prozess","description":"Prozess is a kafka library for Node.js","keywords":["kafka","producer","consumer"],"version":"0.7.0","bugs":{"url":"https://github.com/cainus/Prozess/issues"},"scripts":{"test":"make test-coveralls"},"maintainers":[{"name":"cainus","email":"gregg@caines.ca"}],"contributors":[{"name":"Christoph Tavan"},{"name":"Devon Crouse"},{"name":"Mithun Satheesh","email":"mithunsatish@gmail.com","url":"http://www.linkedin.com/pub/mithun-satheesh/28/89b/a56"}],"dependencies":{"underscore":"1.3.3","buffermaker":"1.0.0","binary":"0.3.0","crc32":"0.2.2","buffer-crc32":"0.2.1","bignum":"0.6.2","readable-stream":"1.0.26"},"devDependencies":{"istanbul":"0.2.8","mocha":"1.3.0","jshint":"2.5.0","coveralls":"1.1.2","jscoverage":"0.3.6","mockery":"1.1.2","hottap":"1.0.1","should":"1.1.0","sinon":"1.5.2"},"main":"index.js","directories":{"test":"test"},"repository":{"type":"git","url":"git://github.com/cainus/Prozess.git"},"engines":{"node":">=0.8.0"},"author":{"name":"Gregg Caines"},"license":"BSD","homepage":"https://github.com/cainus/Prozess","_id":"prozess@0.7.0","dist":{"shasum":"ca26be9e308608c71d8fd45d63a11f101c4d423c","tarball":"https://registry.npmjs.org/prozess/-/prozess-0.7.0.tgz","integrity":"sha512-j90Mh+HL65y/nVSkcs+alGnC54UbqL7Fg98smTKOvlAh1Fbj11msvRyIgqr9fhkWQ3Xk3LxkdomujmLbaMOU5A==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIFcyEGy7o8hFVkwiM1hX40Qu+xqSjpZV5+efILHJzMpgAiEAhTED/8DfehkyTYIzGYcqoU/Szvsoc/PW4Y39SnbL7t0="}]},"_from":".","_npmVersion":"1.4.3","_npmUser":{"name":"cainus","email":"gregg@caines.ca"}},"0.7.1":{"name":"prozess","description":"Prozess is a kafka library for Node.js","keywords":["kafka","producer","consumer"],"version":"0.7.1","bugs":{"url":"https://github.com/cainus/Prozess/issues"},"scripts":{"test":"make test-coveralls"},"maintainers":[{"name":"cainus","email":"gregg@caines.ca"}],"contributors":[{"name":"Christoph Tavan"},{"name":"Devon Crouse"},{"name":"Mithun Satheesh","email":"mithunsatish@gmail.com","url":"http://www.linkedin.com/pub/mithun-satheesh/28/89b/a56"}],"dependencies":{"underscore":"1.3.3","buffermaker":"1.0.0","binary":"0.3.0","crc32":"0.2.2","buffer-crc32":"0.2.1","bignum":"0.6.2","readable-stream":"1.0.26"},"devDependencies":{"istanbul":"0.2.8","mocha":"1.3.0","jshint":"2.5.0","coveralls":"1.1.2","jscoverage":"0.3.6","mockery":"1.1.2","hottap":"1.0.1","should":"1.1.0","sinon":"1.5.2"},"main":"index.js","directories":{"test":"test"},"repository":{"type":"git","url":"git://github.com/cainus/Prozess.git"},"engines":{"node":">=0.8.0"},"author":{"name":"Gregg Caines"},"license":"BSD","homepage":"https://github.com/cainus/Prozess","_id":"prozess@0.7.1","_shasum":"8dd7980eacd955e5a6f8995b4fc6a6776e63ff86","_from":".","_npmVersion":"1.4.9","_npmUser":{"name":"cainus","email":"gregg@caines.ca"},"dist":{"shasum":"8dd7980eacd955e5a6f8995b4fc6a6776e63ff86","tarball":"https://registry.npmjs.org/prozess/-/prozess-0.7.1.tgz","integrity":"sha512-mpaz4Gj9TDgYoWrmn87gNBcnoeZpcPR8t7ihYWqqp4YP9JIFOLIRt/RGXmLiHSxGdjRj95x/JYeg32l851CLtw==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCICeok6fOUZOSJxgfq1Jd8YsxOMSUz6PsJ4HhSTqf1bcuAiAE9l0rRBUh6AvDbk7lN1tyiSPAMziSY3Urie7Xi1QAtg=="}]}},"0.7.2":{"name":"prozess","description":"Prozess is a kafka library for Node.js","keywords":["kafka","producer","consumer"],"version":"0.7.2","bugs":{"url":"https://github.com/cainus/Prozess/issues"},"scripts":{"test":"make test-coveralls"},"maintainers":[{"name":"cainus","email":"gregg@caines.ca"}],"contributors":[{"name":"Christoph Tavan"},{"name":"Devon Crouse"},{"name":"Mithun Satheesh","email":"mithunsatish@gmail.com","url":"http://www.linkedin.com/pub/mithun-satheesh/28/89b/a56"}],"dependencies":{"underscore":"1.3.3","buffermaker":"1.0.0","binary":"0.3.0","crc32":"0.2.2","buffer-crc32":"0.2.1","bignum":"0.6.2","readable-stream":"1.0.26"},"devDependencies":{"istanbul":"0.2.8","jshint":"2.5.0","coveralls":"2.10.0","jscoverage":"0.3.6","mockery":"1.1.2","hottap":"1.0.1","mocha":"1.3.0","should":"1.1.0","sinon":"1.5.2"},"main":"index.js","directories":{"test":"test"},"repository":{"type":"git","url":"git://github.com/cainus/Prozess.git"},"engines":{"node":">=0.8.0"},"author":{"name":"Gregg Caines"},"license":"BSD","homepage":"https://github.com/cainus/Prozess","gitHead":"407b100d8410049907fd5131508d7dae36468d9a","_id":"prozess@0.7.2","_shasum":"6b73c773f311b043143f16dd596205c5517e99c5","_from":".","_npmVersion":"1.4.14","_npmUser":{"name":"cainus","email":"gregg@caines.ca"},"dist":{"shasum":"6b73c773f311b043143f16dd596205c5517e99c5","tarball":"https://registry.npmjs.org/prozess/-/prozess-0.7.2.tgz","integrity":"sha512-S/LzVtz4T0kaxZudJjepqKxpQpy85kFEQ3/xL23cUz1b7zVw1fB3bM3h/zBqrCcT92/qy3iDOsqIKdyf8uveuA==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIHGkP6o0skSc1NkloATRR2rKdd7S/uf26A2N6Tp0DOXBAiEAg/zGWzLkcn2YpFhcZFI7ra1+Gs6PxPROEcKsxXqqApY="}]}},"0.7.3":{"name":"prozess","description":"Prozess is a kafka library for Node.js","keywords":["kafka","producer","consumer"],"version":"0.7.3","bugs":{"url":"https://github.com/cainus/Prozess/issues"},"scripts":{"test":"make test-coveralls"},"maintainers":[{"name":"cainus","email":"gregg@caines.ca"}],"contributors":[{"name":"Christoph Tavan"},{"name":"Devon Crouse"},{"name":"Mithun Satheesh","email":"mithunsatish@gmail.com","url":"http://www.linkedin.com/pub/mithun-satheesh/28/89b/a56"}],"dependencies":{"underscore":"1.3.3","buffermaker":"1.0.0","binary":"0.3.0","crc32":"0.2.2","buffer-crc32":"0.2.1","bignum":"0.6.2","readable-stream":"1.0.26"},"devDependencies":{"istanbul":"0.2.8","jshint":"2.5.0","coveralls":"2.10.0","jscoverage":"0.3.6","mockery":"1.1.2","hottap":"1.0.1","mocha":"1.3.0","should":"1.1.0","sinon":"1.5.2"},"main":"index.js","directories":{"test":"test"},"repository":{"type":"git","url":"git://github.com/cainus/Prozess.git"},"engines":{"node":">=0.8.0"},"author":{"name":"Gregg Caines"},"license":"BSD","homepage":"https://github.com/cainus/Prozess","gitHead":"112e126e38a7e427166b13b2e75c482afc6a0cfb","_id":"prozess@0.7.3","_shasum":"f934b272b856d34450518c56ea550556d4573d54","_from":".","_npmVersion":"1.4.14","_npmUser":{"name":"cainus","email":"gregg@caines.ca"},"dist":{"shasum":"f934b272b856d34450518c56ea550556d4573d54","tarball":"https://registry.npmjs.org/prozess/-/prozess-0.7.3.tgz","integrity":"sha512-EfXCywattTJixT8w0wxCovY1yNeRrvbhBT4SE9hjAi5tmelJXUxqnqOJKiObId1QUUttT+VcphqToWKly5kXjw==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDloPx/rGopaYdwJAQOTzwidYwruU8nMXKRbeVusEEYawIgPI1/4wdJ1Snn7Az6QFgxw9Eb06aLVkdlONqnT6bN+sc="}]}}},"readme":"Prozess\n=======\n[![Build\nStatus](https://secure.travis-ci.org/cainus/Prozess.png?branch=master)](http://travis-ci.org/cainus/Prozess)\n[![Coverage Status](https://coveralls.io/repos/cainus/Prozess/badge.png?branch=master)](https://coveralls.io/r/cainus/Prozess)\n\nProzess is a Kafka library for node.js\n\n[Kafka](http://incubator.apache.org/kafka/index.html) is a persistent, efficient, distributed publish/subscribe messaging system.\n\nThere are two low-level clients: The Producer and the Consumer:\n\n##Producer example:\n\n```javascript\nvar Producer = require('Prozess').Producer;\n\nvar producer = new Producer('social', {host : 'localhost'});\nproducer.connect();\nconsole.log(\"producing for \", producer.topic);\nproducer.on('error', function(err){\n  console.log(\"some general error occurred: \", err);  \n});\nproducer.on('brokerReconnectError', function(err){\n  console.log(\"could not reconnect: \", err);  \n  console.log(\"will retry on next send()\");  \n});\n\nsetInterval(function(){\n  var message = { \"thisisa\" :  \"test \" + new Date()};\n  producer.send(JSON.stringify(message), function(err){\n    if (err){\n      console.log(\"send error: \", err);\n    } else {\n      console.log(\"message sent\");\n    }\n  });\n}, 1000);\n```\n\n##Consumer example:\n\n```javascript\nvar Consumer = require('Prozess').Consumer;\n\nvar options = {host : 'localhost', topic : 'social', partition : 0, offset : 0};\nvar consumer = new Consumer(options);\nconsumer.connect(function(err){\n  if (err) {  throw err; }\n  console.log(\"connected!!\");\n  setInterval(function(){\n    console.log(\"===================================================================\");\n    console.log(new Date());\n    console.log(\"consuming: \" + consumer.topic);\n    consumer.consume(function(err, messages){\n      console.log(err, messages);\n    });\n  }, 7000);\n});\n\n```\n\nA `Consumer` can be constructed with the following options (default values as\nshown below):\n\n```javascript\nvar options = {\n  topic: 'test',\n  partition: 0,\n  host: 'localhost',\n  port: 9092,\n  offset: null, // Number, String or BigNum\n  maxMessageSize: Consumer.MAX_MESSAGE_SIZE,\n  polling: Consumer.DEFAULT_POLLING_INTERVAL\n};\n```\n\n##Documentation\n\n### `var producer = new Producer(options)`\n\n```ocaml\ntype Message := String | Buffer\n\nProducer := ({\n  topic: String,\n  partition?: Number,\n  host?: String,\n  port?: Number,\n  connectionCache?: Boolean\n}) => EventEmitter & {\n  connect: () => void,\n  send: (Array<Message> | Message, opts?: {\n    partition?: Number,\n    topic?: String\n  }, cb: Callback<>) => void\n}\n```\n\nTo create a `producer` you must call `Producer()` with various\n  options. The only required argument is the topic your\n  producing to.\n  \n```js\nvar Producer = require('prozess').Producer\n\nvar producer = new Producer({ topic: 'foos' })\n```\n\n#### `options.topic`\n\n`options.topic` must be a `String` and is the topic\n  in kafka that you will producer to\n  \n#### `options.partition`\n\n`options.partition` is an optional `Number` and \n  defaults to `0`. You can specify this if you want\n  to change which `partition` you publish to.\n  \n#### `options.host` and `options.port`\n\n`options.host` determines the host location of the\n  kafka node you are connecting to and `options.port`\n  determines the port.\n  \nThese default to `\"localhost\"` and `9092` which are \n  the default kafka ports.\n  \n#### `options.connectionCache`\n\n`options.connectionCache` is a `Boolean` you can set\n  to opt in into connection caching. By default `prozess`\n  will create one TCP connection per topic.\n  \nIf you set `options.connectionCache` to true then \n  `prozess` will use one TCP connection per host & port.\n  \n#### `producer.connect(Callback)`\n\nYou can call `producer.connect(cb)` to open your connection\n  to kafka, the `cb` you pass in will be called once the\n  connection is open.\n  \nYou must call `.connect()` before calling `.send()`\n\n#### `producer.send(Message, opts?: Object, Callback)`\n\nTo produce messages to kafka you should call `.send()` with\n  either an array of `String`'s or a single `String`.\n  \nYou can pass `.send()` an optional options argument to \n  customize the `topic` & `partition` for this single `send()`\n  request.\n  \nYou must also supply a `Callback` to handle any asynchronous\n  errors.\n\n##Installation:\n\n     npm install prozess\n\n##Checkout the code and run the tests:\n\n     $ git clone https://github.com/cainus/Prozess.git\n     $ cd Prozess ; make test-cov && open coverage.html\n\n\n##Kafka Compatability matrix:\n\n<table>\n  <tr>\n     <td>Kakfa 0.8.0 Release</td><td>Not Supported</td>\n  </tr>\n  <tr>\n    <td>Kafka 0.7.2 Release</td><td>Supported</td>\n  <tr>\n    <td>Kafka 0.7.1 Release</td><td>Supported</td>\n  <tr>\n    <td>Kafka 0.7.0 Release</td><td>Supported</td>\n  <tr>\n    <td>kafka-0.6</td><td>Not Supported</td>\n  <tr>\n    <td>kafka-0.05</td><td>Not Supported</td>\n</table>\n\nVersions taken from http://incubator.apache.org/kafka/downloads.html\n","maintainers":[{"name":"cainus","email":"gregg@caines.ca"}],"time":{"modified":"2022-06-24T22:14:51.167Z","created":"2012-09-26T18:07:58.622Z","0.1.0":"2012-09-26T18:07:59.996Z","0.1.1":"2012-09-26T21:58:01.067Z","0.1.2":"2012-10-08T16:39:53.834Z","0.2.0":"2012-10-11T23:31:18.673Z","0.2.1":"2012-10-15T20:12:27.484Z","0.2.2":"2013-01-09T18:47:09.302Z","0.2.3":"2013-01-10T16:34:59.080Z","0.3.0":"2013-01-23T23:31:30.866Z","0.3.1":"2013-01-31T23:58:55.036Z","0.3.2":"2013-04-04T05:36:41.325Z","0.3.3":"2013-04-04T23:15:39.924Z","0.3.4":"2013-04-05T02:35:20.037Z","0.3.5":"2013-04-11T15:17:23.205Z","0.3.6":"2013-04-26T22:53:47.903Z","0.3.7":"2013-06-13T20:33:32.516Z","0.4.0":"2013-07-11T21:14:40.796Z","0.5.0":"2013-07-15T21:48:31.234Z","0.6.0":"2013-07-15T22:49:33.695Z","0.6.1":"2013-07-27T20:00:26.509Z","0.6.2":"2013-09-13T17:07:44.960Z","0.6.3":"2013-09-13T17:40:15.472Z","0.6.4":"2013-09-16T20:19:12.111Z","0.7.0":"2014-05-05T03:25:50.434Z","0.7.1":"2014-05-07T14:58:47.961Z","0.7.2":"2014-08-18T14:19:33.303Z","0.7.3":"2014-09-30T17:41:37.226Z"},"repository":{"type":"git","url":"git://github.com/cainus/Prozess.git"},"homepage":"https://github.com/cainus/Prozess","keywords":["kafka","producer","consumer"],"contributors":[{"name":"Christoph Tavan"},{"name":"Devon Crouse"},{"name":"Mithun Satheesh","email":"mithunsatish@gmail.com","url":"http://www.linkedin.com/pub/mithun-satheesh/28/89b/a56"}],"author":{"name":"Gregg Caines"},"bugs":{"url":"https://github.com/cainus/Prozess/issues"},"license":"BSD","readmeFilename":"README.md","users":{"rkielty":true,"developit":true}}