npm packagekafka-node (npm package)

Client for Apache Kafka v0.9.x, v0.10.x and v0.11.x


GitHub repos using kafka-node (showing top 100 with most stars)

#GitHub repo nameStars
1moleculerjs/moleculer2.8k
2wangweianger/egg-mongoose-performance-system500+
3DAVFoundation/missioncontrol100+
4kafka-lens/kafka-lens100+
5josephg/sephsplace100+
6DAVFoundation/dav-js70+
7SIB-Colombia/dataportal-explorer60+
8TarsCloud/TarsWeb50+
9SomeKittens/gustav40+
10tholman/the-internet40+
11davidemiceli/chainode40+
12theotow/nodejs-kafka-example40+
13duyetdev/realtime-dashboard30+
14mikfreeman/chatme_kafka20+
15instana/nodejs-sensor20+
16TNOCS/csWeb20+
17oslabs-beta/kafka-lens20+
18joynal/kafka-experiment20+
19ldaniels528/qwery20+
20Quinton/egg-kafkajs20+
21burning0xb/api-rest10+
22JohnApache/egg-kafka-node10+
23narcisoguillen/kafka-node-avro10+
24Unity-Technologies/Tanto10+
25teambition/loghub-core10+
26ghermeto/socket.io-kafka10+
27chaintng/panda-crypto-bot10+
28telepat-io/telepat-models10+
29hchowdhary/VisualizingStreamingData10+
30huseyinbabal/twitter-stream10+
31SoftwareEngineeringDaily/sedaily-devops10+
32Alethio/ethstats-network-server10+
33that-coder/kafka-example10+
34ntfs32/egg-kafka10+
35jlandersen/vscode-kafka10+
36F5Networks/f5-telemetry-streaming10+
37topcoderinc/dsp-server9
38xisiot/lora-system8
39xblockchainlabs/willa8
40streamr-dev/data-api8
41royaltm/kafka-tools8
42fwang7/node-red-contrib-kafka-node7
43deepstreamIO/deepstream.io-msg-kafka7
44yhj2009/egg-kafkajs26
45louiswilliams/mongodb-kafka-changestreams6
46felipesabino/nodejs-express-kafka-mongodb6
47e-ucm/rage-analytics-backend6
48cointradingbot/tradebot6
49IndustrialCloudSolutions/loopback-connector-kafka6
50CUBigDataClass/BigMood-API6
51Avocarrot/winston-kafka6
52yunong/bunyan-kafka5
53thynson/kafka-pipeline5
54mfaulk/socketio-kafka5
55lammoth/thedashboard5
56joegaffey/rock-star5
57Nodics/nodics5
58MoritzGiessmann/naiveScript5
59Financial-Times/email-users-kafka-consumer5
60Asymmetrik/mean2-starter5
61zuoez02/log4js-kafka-appender4
62solzimer/nsyslog4
63sleighzy/moleculer-microservices-spike4
64scottpersinger/mysql-to-kafka4
65nokk/winston-kafka4
66nirdizati/nirdizati-runtime4
67ldaniels528/shocktrade.js4
68laurindo/kafka-socketio-nodejs4
69kongnet/skybase4
70jlandersen/kafka-control4
71SciCatProject/catamel4
72RenmanKang/KafkaWebMonitor4
73ENOW-IJI/ENOW-console4
74BlueBrain/nexus-search-webapp4
75xisiot/lora-network-server3
76xisiot/lora-application-server3
77tomgrek/openiotdash3
78strongloop/loopback4-example-kafka3
79streamsight/streamsight3
80restorecommerce/kafka-client3
81ouyangxuanyun/Kafka_UI3
82mbarth/twitter-stream-kafka-producer3
83manymeeting/movie-kingdom-client3
84kelveden/confluent-cli3
85jpgraber/winston-kafka-stream3
86jpg013/winston-kafka-stream3
87jezzalaycock/kafka-node-manager3
88hoppity/kafka-http-proxy3
89harryluo163/miaosha3
90enudler/kafka-consumer-manager3
91behrad/mom3
92amarpreetsingh29/node-workflows3
93agencyrevolution/ar-workflow-helpers3
94XadillaX/mikasa3
95Vinylize/graphql-server3
96Sleaf/DistributedServerTest3
97RuntimeTools/appmetrics-kafka3
98PhyrexTsai/blockchainbox-node3
99JozefStefanInstitute/StreamStory3
100GaiamTV/kafka-node-topic-consumer3
101CuveeCui/nego3
102yuedun/kafka-MQ2
103xuren87/node-red-contrib-kafkanode2
104wtelecom/thedashboard2
105vunguyenhung/kafka-node-driver2
106varunon9/audit-logging-framework2
107tinchoz49/moleculer2
108simsieg/Kafka-Docker-Node.js2
109simonireilly/kafka-webhook-dispatcher2
110phandinhloc/simple-kafka-node2
111pedrosousabarreto/node-microsvc-example2
112monkybrain/kafka-rxjs2
113mfaulk/angular-websocket-kafka2
114mafesernaarboleda/kafka-node-iot2
115lucasjellema/eventmonitor-microservice-soaring-clouds-sequel2
116leodisarli/kafka-node-example2
117jamestthompson3/reason-kafka2
118inkless/node-db-migrator2
119iilunin/node-ws-kafka-connector2
120hoppity/kafka-consumer-monitor2
121hjwgit/Debezium-mysql-connector2
122harelba/mail2kafka2
123haio/loopback-connector-kafka2
124epfl-dojo/servicenow-kafka2
125ekinsokmen/kafka-json-consumer2
126dgaydukov/nodejs-cce-core-connector2
127comparaonline/event-streamer2
128chrislarsenqlik/Qonductor2
129callofdutyops/cnc-data-simulator2
130benmizrahi/Kxplore2
131anserran/gleaner-frontend2
132andeaseme/backbeat2
133aaronz/simple-node-crawler2
134Theembers/iot-processer2
135ReGIS-org/regis2
136ProboCI/probo-db2
137JonathanBennett/marathon-metric-forwarder2
138GridvoDev/gridvo-wechat2
139ExpediaDotCom/haystack-client-node2
140Cmdv/Cyclejs-kafka-socketio-consumer2
141zpc10/red_packets_game1
142zhenfeng-zhu/node-koa1
143zeqi/zeqi.common1
144zenvia/node-connector-base1
145zaiddabaeen/realtime-traffic-map1
146yldio/msb1
147yeyuguo/zanePerfor1
148xisiot/lora-join-server1
149xhackax47/moleculer1
150wucpeng/express-kafka1
151wenshaoyan/log4j2-node1
152wenisman/kafka-http-proxy1
153wangjp19951024/node-webkit1
154udacity/node-kafka-adapter1
155traveldevel/iot-hub-ingestion-rest1
156tq1/express-kafka-producer1
157torns/zanePerfor1
158thalescm/nodejs-express-kafka-mongodb1
159struthj/kafka-node-docker-mysql-example1
160stenver/node-kafka-producer-service1
161specialblend/kafka-pipe1
162songxuy/cloud-nine1
163sharafian/the-metamorphosis1
164sematext/logagent-input-kafka1
165scalajs-io/kafka-node1
166sark01/dav-js1
167saran87/mercury1
168samuraraujo/bitfinex-hackathon-20181
169ru-rocker/node-express-kafka1
170robsonquaresma/kafka-com-node1
171quintoandar/node-kafka1
172pratikEI/willa1
173porsich/kafka-node-example1
174poojaKarande13/streaming-data1
175ozthekoder/integration-tester1
176ouyangxuanyun/KafkaManagerVue1
177opencollective/moleculer1
178obsoke/loggy-with-kafka1
179musaberatbahadir/grpc-nodeJS-Kafka1
180msdgwzhy6/zanePerfor1
181moonken/nestjs-kafka-websocket-demo1
182mikefaraponov/logs1
183miguelveces/kafka-node_implement1
184maninder-singh/socket-kafka-integration1
185lucasefe/radar-runner1
186lovato/Kafka-NodeJS-Client-Test1
187locol-media-dev/locol.common.services1
188liwimoi/node-server1
189limengyu1990/report1
190kyledavelaar/koa-api-21
191kyledavelaar/koa-api1
192kyledavelaar/kafka-node21
193ksuperman/cleanstreet_server1
194klemenkenda/iot-fusion1
195keawade/moleculer1
196kaziwaseef/kafka-experiment1
197jonathangersam/kafka-node-example1
198joaopitacosta/StreamStory1
199jgtonys/Spark-Structured-Streaming1
200jcoopere/node-red-contrib-cloudera1
201jackielihf/winston-k1
202isaacmg/kafka-d3js1
203isWangZL/TarsWeb1
204hyperlink/kafka-message-length1
205howardNa/kafka-lens1
206hjSundog/e-civ-api1
207heyuguan/vue-koa1
208heroku/data-driven-demo1
209helloravi/starter-kit-node1
210heitormejias/kafka-topic-js1
211hcxiong/moleculer1
212guthega/guthega1
213green-dash/stream-viz1
214go-alfred/poc1
215giang12/winston-kafka-connect1
216garo/scribe2kafka1
217fortress-shell/logs1
218flentini/artillery-engine-kafka1
219faeron/moleculer1
220erbrother/vue-bigdata1
221e174596549/queue-schedule1
222ducas/kafka-http-proxy1
223ducas/kafka-consumer-monitor1
224dlorian/node-kafka1
225dingchaolin/node-rpc1
226dgaydukov/nodejs-cce-blockchain-ethereum1
227debragail/missioncontrol1
228debragail/dav-js1
229deathcore666/kafkaExampleApp1
230darcyturk/moleculer1
231daanpeer/scrumulator1
232cruzj6/game-pop-poller1
233crato-logging/crato1
234cr22rc/node-red-contrib-kafka-node1
235btccom/poolEventLogs1
236botkop/botkop-telcotraffic-viz-node1
237bimedia-fr/architect-kafka1
238bigdatr/winston-kafka-transport1
239beiyannanfei/test1
240azapps/wait-for-kafka1
241ayoah/js-collection1
242ajay96688/socket.io-kafka1
243abhi12299/gRPC-Tracking-Server1
244aadisriram/WikiCrawler1
245YumingHe/ethstats-network-server1
246YiliaYilia/egg-kafka1
247YanlongLai/blockchainbox-node1
248Woorank/kafka-test1
249WesleyBatista/docker-dashboard1
250UKHomeOffice/platform_queue_service1
251Txiaozhe/js-modules1
252TNOCS/csWeb-dist1
253Sufiane/front_api1
254Suezenv/node-red-contrib-kafka-node1
255ProofOfTransaction/proofoftransaction-core1
256ProboCI/probo-reaper1
257ProboCI/probo-eventbus1
258Nirilanto/moleculer1
259NeuCleans/kafka-pub-sub1
260Netsrfr/backbeat1
261NAPS-emergency-response-project/frontend-manager1
262MattDiMu/moleculer1
263Marvinified/HyperService1
264ManjunathKmph/twitter-sentiment1
265LesTR/tw-realtime-wordcloud1
266Juanitoclement/FE-SmartHome1
267Jossaya/KafkaMessagesStreams1
268IsCaster/wushuu_node_common1
269ISNIT0/kafka-testing-tools1
270Hellofafar/realtime-dashboard1
271HashanAbeysinghe/NodeKafkaClient1
272DubFriend/maxwell-redis1
273DRIVER-EU/node-test-bed-adapter1
274DBProductions/nodejs-stuff1
275ConduentLCS/mercury1
276BlueCodeSystems/openmrs-middleware1
277Aymanov1/tipi1
278Asymmetrik/node-rest-starter1
279Asymmetrik/meanjs-starter1
280Arjun-tp/kafka_producer_consumer1
281Arjun-tp/StoreVideoToMongo1
282755966092/node-crawler-yiche1