Reputation: 854
I have a simple web which can display stock price streaming of certain stock symbol. The web server is nodejs, the infrastructure for stock processing is kafka, spark with python. The flow is
googlefinnace -> kafka(pythonfile 1) -> spark(pythonfile2) -> nodejs -> web browser
The explanation : kafka and spark process stock info from google finance, then provide result to nodejs web server. However the stock symbol is hardcode to "FB". so I wanna user can type desired stock symbol on web, and nodejs can send it back to kafka(pythonfile1). I don't know how to do it between nodejs and kafka . Could anyone weigh in here?
Thanks
Upvotes: 0
Views: 468
Reputation: 8335
There are several very good nodejs Kafka clients. I personally use node-rdkafka
https://github.com/Blizzard/node-rdkafka
Using any of these nodejs Kafka clients you can publish or subscribe to any Kafka topic from your nodejs web application.
Upvotes: 1