nodejs web服务器与python通信

Question

我有一个简单的网页，可以显示股票价格流的某些股票符号。web服务器是nodejs，股票处理的基础设施是kafka，spark with python。流程是

googlefinnace->卡夫卡（pythonfile 1）->spark（pythonfile2）->nodejs->；web浏览器

解释：kafka和spark处理来自googlefinance的股票信息，然后将结果提供给nodejs的web服务器。但是股票代码是硬编码为“FB”。 所以我希望用户可以在网上输入想要的股票代码，而nodejs可以把它发送回kafka（pythonfile1）。我不知道在野田和卡夫卡之间怎么做。有人能称一下吗？在

谢谢

Answer 1

有几个非常好的nodejs-Kafka客户。我个人使用node rdkafka

https://github.com/Blizzard/node-rdkafka

使用这些nodejs-Kafka客户机，您可以从nodejs web应用程序发布或订阅任何Kafka主题。在