{"_id":"kafka","_rev":"27-d7dbe6a2c93b02559a478c085960003c","name":"kafka","description":"A node client for Kafka","dist-tags":{"latest":"0.2.3"},"versions":{"0.1.3":{"name":"kafka","description":"A node client for Kafka","version":"0.1.3","homepage":"https://github.com/marcuswestin/kafka-node-client","author":{"name":"Marcus Westin","email":"narcvs@gmail.com","url":"http://marcuswest.in"},"repository":{"type":"git","url":"git://github.com/marcuswestin/kafka-node-client.git"},"bugs":{"url":"http://github.com/marcuswestin/kafka-node-client/issues"},"engines":{"node":"*"},"licenses":[{"type":"MIT","url":"http://github.com/marcuswestin/kafka-node-client/raw/master/LICENSE"}],"main":"kafka-node","directories":{"lib":"."},"files":[""],"_id":"kafka@0.1.3","_engineSupported":true,"_npmVersion":"0.3.17","_nodeVersion":"v0.4.2","_defaultsLoaded":true,"dist":{"shasum":"1052ec40d9c63675dfd4720824d56925845e52b1","tarball":"https://registry.npmjs.org/kafka/-/kafka-0.1.3.tgz","integrity":"sha512-mmk+2Y0F7XCaC8x/Ko/7rG8NWjm/OcALQsGb96AHnGnTY0wMh5reDGCqjBiOJxiXuvD5WPqtjKA+vPuuS/YFig==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEYCIQCy8uabKZS24xECD2S6LNlTD4xbmq4F6hi7638m2t3s9QIhAOhRk67r3knAPtUCYTpGFMh7aDuTGohxksAjALH+PdDZ"}]}},"0.1.4":{"name":"kafka","description":"A node client for Kafka","version":"0.1.4","homepage":"https://github.com/marcuswestin/node-kafka","author":{"name":"Marcus Westin","email":"narcvs@gmail.com","url":"http://marcuswest.in"},"repository":{"type":"git","url":"git://github.com/marcuswestin/node-kafka.git"},"bugs":{"url":"http://github.com/marcuswestin/node-kafka/issues"},"engines":{"node":"*"},"licenses":[{"type":"MIT","url":"http://github.com/marcuswestin/node-kafka/raw/master/LICENSE"}],"main":"kafka-node","directories":{"lib":"."},"files":[""],"_id":"kafka@0.1.4","_engineSupported":true,"_npmVersion":"0.3.17","_nodeVersion":"v0.4.2","_defaultsLoaded":true,"dist":{"shasum":"988e44ffb2ef8a9d80490ba47525c4ad99ef1009","tarball":"https://registry.npmjs.org/kafka/-/kafka-0.1.4.tgz","integrity":"sha512-rb9ljZV1t+cMKz62M7HMDiiRHjkBvKvb8IaENb/E8/BaVrsWAqbacnPZG77ymuuq86yjChmsL9wxvxBf0O3N6A==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIBwYGs7bD4QCP1kjUxuVn2wIHZPVS5dMYBhBNJSas5s6AiAMOqE60C7eGKhD18yC/Nqvq0/7Pp1jY5OdP85aEaPzVg=="}]}},"0.1.6":{"name":"kafka","description":"A node client for Kafka","version":"0.1.6","homepage":"https://github.com/marcuswestin/node-kafka","author":{"name":"Marcus Westin","email":"narcvs@gmail.com","url":"http://marcuswest.in"},"dependencies":{"std":"= 0.1.8"},"repository":{"type":"git","url":"git://github.com/marcuswestin/node-kafka.git"},"bugs":{"url":"http://github.com/marcuswestin/node-kafka/issues"},"engines":{"node":"*"},"licenses":[{"type":"MIT","url":"http://github.com/marcuswestin/node-kafka/raw/master/LICENSE"}],"main":"kafka","directories":{"lib":"lib"},"files":[""],"_id":"kafka@0.1.6","_engineSupported":true,"_npmVersion":"0.3.17","_nodeVersion":"v0.4.5","_defaultsLoaded":true,"dist":{"shasum":"31d61d184d640fe4a585492e377b9bb63d187a71","tarball":"https://registry.npmjs.org/kafka/-/kafka-0.1.6.tgz","integrity":"sha512-n3+qCnAt0UjnsMD0/8e+37X4Gn0ZF/7SRG1K1KI5DCH0NUDo8Gra5WdSj2XQYEUKH4aTxqIw6r4V+4FbuQOojQ==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQCIdvWJMBEkBVZeej4J7el4szbZbtia89WZzZTRYYJIeAIgJ0MjYuZ7A/GTVvm3pwP7viEzjAybaK2amW/eP/rXBAs="}]}},"0.1.7":{"name":"kafka","description":"A node client for Kafka","version":"0.1.7","homepage":"https://github.com/marcuswestin/node-kafka","author":{"name":"Marcus Westin","email":"narcvs@gmail.com","url":"http://marcuswest.in"},"dependencies":{"std":"= 0.1.8"},"repository":{"type":"git","url":"git://github.com/marcuswestin/node-kafka.git"},"bugs":{"url":"http://github.com/marcuswestin/node-kafka/issues"},"engines":{"node":"*"},"licenses":[{"type":"MIT","url":"http://github.com/marcuswestin/node-kafka/raw/master/LICENSE"}],"main":"kafka","directories":{"lib":"lib"},"files":[""],"_id":"kafka@0.1.7","_engineSupported":true,"_npmVersion":"0.3.17","_nodeVersion":"v0.4.5","_defaultsLoaded":true,"dist":{"shasum":"ac9423e0106ce2e55c3979f5b79d3f9f2769e855","tarball":"https://registry.npmjs.org/kafka/-/kafka-0.1.7.tgz","integrity":"sha512-Veedd9ghRujiYawjo4QXbcnpMYiRR33H4B6rAVk6yJlT0/1/2Ydj0tcI2oBSiVYzVZr/zPeJFIi62cTW4OTjzA==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDCelXSEzZe2gW/NH/9jgopPKo4K/bZNpUhnknc865LMAIgKtHJvLOLllaq5Ny3H5HS4b4jsYmT8vaayNFMN3lT0jI="}]}},"0.2.0":{"name":"kafka","description":"A node client for Kafka","version":"0.2.0","homepage":"https://github.com/marcuswestin/node-kafka","author":{"name":"Marcus Westin","email":"narcvs@gmail.com","url":"http://marcuswest.in"},"repository":{"type":"git","url":"git://github.com/marcuswestin/node-kafka.git"},"bugs":{"url":"http://github.com/marcuswestin/node-kafka/issues"},"engines":{"node":"*"},"licenses":[{"type":"MIT","url":"http://github.com/marcuswestin/node-kafka/raw/master/LICENSE"}],"main":"kafka","directories":{"lib":"lib"},"files":[""],"_npmUser":{"name":"marcuswestin","email":"narcvs@gmail.com"},"_id":"kafka@0.2.0","dependencies":{},"devDependencies":{},"_engineSupported":true,"_npmVersion":"1.0.103","_nodeVersion":"v0.4.12","_defaultsLoaded":true,"dist":{"shasum":"3705738f326d00846afcd99bda90227626a85499","tarball":"https://registry.npmjs.org/kafka/-/kafka-0.2.0.tgz","integrity":"sha512-fSMHbXebS3Cswm88ikb81aqE7pWr8jtq4WKTUVfVQBhrmJO1hWMKO67dWNV2jZkxXMwM4o0ZR/c6vEWcFLvtcA==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIGEpUSUZO44MqyX7+3x8gG6lYreKh3aUHMt01mjW3ZPeAiEA9S3XLTCnmlxlWcSeneJnh/2+HDN1nmRcHJJCNNr29AQ="}]},"maintainers":[{"name":"marcuswestin","email":"narcvs@gmail.com"}]},"0.2.1":{"name":"kafka","description":"A node client for Kafka","version":"0.2.1","homepage":"https://github.com/marcuswestin/node-kafka","author":{"name":"Marcus Westin","email":"narcvs@gmail.com","url":"http://marcuswest.in"},"repository":{"type":"git","url":"git://github.com/marcuswestin/node-kafka.git"},"bugs":{"url":"http://github.com/marcuswestin/node-kafka/issues"},"engines":{"node":"*"},"licenses":[{"type":"MIT","url":"http://github.com/marcuswestin/node-kafka/raw/master/LICENSE"}],"main":"kafka","dependencies":{"std":"0.1.28"},"directories":{"lib":"lib"},"files":[""],"_npmUser":{"name":"marcuswestin","email":"narcvs@gmail.com"},"_id":"kafka@0.2.1","devDependencies":{},"_engineSupported":true,"_npmVersion":"1.0.103","_nodeVersion":"v0.4.12","_defaultsLoaded":true,"dist":{"shasum":"b9b145f17b4d4865d144d2c004365cf903e112fc","tarball":"https://registry.npmjs.org/kafka/-/kafka-0.2.1.tgz","integrity":"sha512-dZBOcQNjeiXaS2itT098cvwwcXQ/jpFV8dopLQ1ACjMhW5kyfq7B/K9TyERf4RDXDmpzsz3CPqRE7YnqZcUNxw==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIFqkhCrZYh6Ymz61SY3WNyz6UuvZUlZMgSfRw8ef9GGYAiBPxKRbIBodHXW1Ic/l4qYGyoAG4iTLtReoFUv3fnAbvA=="}]},"maintainers":[{"name":"marcuswestin","email":"narcvs@gmail.com"}]},"0.2.2":{"name":"kafka","description":"A node client for Kafka","version":"0.2.2","homepage":"https://github.com/marcuswestin/node-kafka","author":{"name":"Marcus Westin","email":"narcvs@gmail.com","url":"http://marcuswest.in"},"repository":{"type":"git","url":"git://github.com/marcuswestin/node-kafka.git"},"bugs":{"url":"http://github.com/marcuswestin/node-kafka/issues"},"engines":{"node":"*"},"licenses":[{"type":"MIT","url":"http://github.com/marcuswestin/node-kafka/raw/master/LICENSE"}],"main":"kafka","dependencies":{"std":"0.1.36"},"directories":{"lib":"lib"},"files":[""],"readme":"Main project repo moved\n-----------------------\nThis project is most actively used and maintained by Taylor Gautier at Tagged.\n\nPlease see the [Tagged node-kafka repo](https://github.com/tagged/node-kafka).\n\n\nKafka javascript API\n-----------------------\nInteract with [Kafka](http://sna-projects.com/kafka/), LinkedIn's disk based message queue using node.js\n\nGet up and running\n------------------\n\n 1 Install kafka\n\n\tnpm install kafka\n\n 2 Start zookeeper, kafka server, and a consumer (see http://sna-projects.com/kafka/quickstart.php)\n\n 3 Publish and consume some messages!\n\n\tvar kafka = require('kafka')\n\t\n\tnew kafka.Consumer().connect().subscribeTopic('test').on('message', function(topic, message) {\n\t\tconsole.log(\"Consumed message:\", message)\n\t})\n\t\n\tvar producer = new kafka.Producer().connect().on('connect', function() {\n\t\tproducer.send(\"hey!\")\n\t\tproducer.close()\n\t})\n\nAPI\n---\n\n`kafka.Consumer`\n\n\tvar consumer = new kafka.Consumer({\n\t\t// these are the default values\n\t\thost:         'localhost',\n\t\tport:          9092,\n\t\tpollInterval:  2000,\n\t\tmaxSize:       1048576 // 1MB\n\t})\n    consumer.on('message', function(topic, message) { \n        console.log(message)\n    })\n\tconsumer.connect(function() {\n        consumer.subscribeTopic({name: 'test', partition: 0})\n    })\n\n`kafka.Producer`\n\n\tvar producer = new kafka.Producer({\n\t\t// these are also the default values\n\t\thost:         'localhost',\n\t\tport:         9092,\n\t\ttopic:        'test',\n\t\tpartition:    0\n\t})\n\tproducer.connect(function() {\n\t\tproducer.send('message bytes')\n\t})\n\nAuthors\n-------\n\n- Marcus Westin (clover)\n- Taylor Gautier (tagged)\n\nContributors\n------------\n\n- Laurie Harper\n- @omnichuck\n- @philips\n","_id":"kafka@0.2.2","dist":{"shasum":"b794d1e9f82426ebac5eec2b623c816d36ed96bb","tarball":"https://registry.npmjs.org/kafka/-/kafka-0.2.2.tgz","integrity":"sha512-gzWO3bN2MeXqOQYb0cqttyPJbHGG/E2nr+uU+yf24NnXFl2nkbKAWCh02XGHPRvYqgUq5L09d+7RG5E7OtmfpA==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEUCIQDbeoDat44BSD32LHiFS+cPcUCpEPvRwAxOEYQL9GHIYgIgDA6gTdT0t5dhyeeO+yzbPiMTZdsztNlS+j1Z3o/JUhw="}]},"_npmVersion":"1.1.49","_npmUser":{"name":"marcuswestin","email":"narcvs@gmail.com"},"maintainers":[{"name":"marcuswestin","email":"narcvs@gmail.com"}]},"0.2.3":{"name":"kafka","description":"A node client for Kafka","version":"0.2.3","homepage":"https://github.com/marcuswestin/node-kafka","author":{"name":"Marcus Westin","email":"narcvs@gmail.com","url":"http://marcuswest.in"},"repository":{"type":"git","url":"git://github.com/marcuswestin/node-kafka.git"},"bugs":{"url":"http://github.com/marcuswestin/node-kafka/issues"},"engines":{"node":"*"},"licenses":[{"type":"MIT","url":"http://github.com/marcuswestin/node-kafka/raw/master/LICENSE"}],"main":"kafka","dependencies":{"std":"0.1.36"},"directories":{"lib":"lib"},"files":[""],"readme":"Main project repo moved\n-----------------------\nThis project is most actively used and maintained by Taylor Gautier at Tagged.\n\nPlease see the [Tagged node-kafka repo](https://github.com/tagged/node-kafka).\n\n\nKafka javascript API\n-----------------------\nInteract with [Kafka](http://sna-projects.com/kafka/), LinkedIn's disk based message queue using node.js\n\nGet up and running\n------------------\n\n 1 Install kafka\n\n\tnpm install kafka\n\n 2 Start zookeeper, kafka server, and a consumer (see http://sna-projects.com/kafka/quickstart.php)\n\n 3 Publish and consume some messages!\n\n\tvar kafka = require('kafka')\n\t\n\tnew kafka.Consumer().connect().subscribeTopic('test').on('message', function(topic, message) {\n\t\tconsole.log(\"Consumed message:\", message)\n\t})\n\t\n\tvar producer = new kafka.Producer().connect().on('connect', function() {\n\t\tproducer.send(\"hey!\")\n\t\tproducer.close()\n\t})\n\nAPI\n---\n\n`kafka.Consumer`\n\n\tvar consumer = new kafka.Consumer({\n\t\t// these are the default values\n\t\thost:         'localhost',\n\t\tport:          9092,\n\t\tpollInterval:  2000,\n\t\tmaxSize:       1048576 // 1MB\n\t})\n    consumer.on('message', function(topic, message) { \n        console.log(message)\n    })\n\tconsumer.connect(function() {\n        consumer.subscribeTopic({name: 'test', partition: 0})\n    })\n\n`kafka.Producer`\n\n\tvar producer = new kafka.Producer({\n\t\t// these are also the default values\n\t\thost:         'localhost',\n\t\tport:         9092,\n\t\ttopic:        'test',\n\t\tpartition:    0\n\t})\n\tproducer.connect(function() {\n\t\tproducer.send('message bytes')\n\t})\n\nAuthors\n-------\n\n- Marcus Westin (clover)\n- Taylor Gautier (tagged)\n\nContributors\n------------\n\n- Laurie Harper\n- @omnichuck\n- @philips\n","_id":"kafka@0.2.3","dist":{"shasum":"fb7b1df38f161d821fee9dcb63985e388ea08188","tarball":"https://registry.npmjs.org/kafka/-/kafka-0.2.3.tgz","integrity":"sha512-Qi9J1HgikGlZz4dGzG++sZ3L52JTE+LCWelz3MNmze0KePSeWvZHVtGe981/mD/u+wyLg6INFw3Rgrqyg+orTA==","signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCIDwvps5FQ3bDBJ5pf9DczTi4fIYBaviDalTo2YDXnEC4AiAs+eTjnh/4WJhRH3e0bRAqznsW7DvJ39yz6QG8Ehtrmw=="}]},"_npmVersion":"1.1.49","_npmUser":{"name":"marcuswestin","email":"narcvs@gmail.com"},"maintainers":[{"name":"marcuswestin","email":"narcvs@gmail.com"}]}},"maintainers":[{"name":"marcuswestin","email":"narcvs@gmail.com"}],"time":{"modified":"2022-06-19T07:42:44.131Z","created":"2011-03-31T19:28:26.608Z","0.1.3":"2011-03-31T19:28:26.893Z","0.1.4":"2011-03-31T19:32:18.236Z","0.1.6":"2011-04-05T03:34:56.427Z","0.1.7":"2011-04-05T04:19:35.719Z","0.2.0":"2011-12-19T02:48:21.499Z","0.2.1":"2011-12-19T07:16:47.616Z","0.2.2":"2012-12-09T16:59:25.212Z","0.2.3":"2012-12-09T17:02:32.681Z"},"author":{"name":"Marcus Westin","email":"narcvs@gmail.com","url":"http://marcuswest.in"},"repository":{"type":"git","url":"git://github.com/marcuswestin/node-kafka.git"},"users":{"keberox":true,"eterna2":true,"gonprazeres":true,"mehrantm":true,"nickeltobias":true,"mano.rajesh":true}}