最新版本的ibm消息总线是否支持kafka流（此处描述：http://www.confluent.io/blog/introducing-kafka-streams-stream-processing-made-simple/). 有关于如何做到这一点的例子/例子吗？如果是，是否可以使用node.js完成此操作？
我想做的是
将数据从源数据库（cloudant）流到kafka流（bluemix-beta服务中存在连接器服务）
使用kafka流聚合数据（摘要、计数等）
web Jmeter 板应用程序-前端（node.js，d3.js）使用流并实时更新 Jmeter 板。
谢谢您
1条答案
按热度按时间cyej8jka1#
您完全可以使用node.js发布和订阅kafka（又名ibmmessagehub），并且可以在各种 Jmeter 板中可视化kafka数据。最近我一直在使用node red和node red Jmeter 板以及node red contrib web worldmap，效果很好。
nodejs应用程序的pub/sub可以通过合流rest代理（ibmmessagehub使用）或通过本机node.js客户机完成，就像暴雪在librdkafka之上编写的那样（请参阅https://github.com/blizzard/node-rdkafka). confluent编写了一些nodejs Package 函数，以便更容易使用rest代理（请参阅https://github.com/confluentinc/kafka-rest-node)
就kafka流而言，目前支持的主要语言是java和scala。您可以将javascript中的节点客户机与java中的streams应用程序混合使用，而不会产生任何问题。kafka streams实现为一个java库，因此您的streams应用程序一定会在bluemix虚拟机或容器中运行，并且它们不需要任何额外的集群管理器或第三方基础设施。
更新：ibm宣布messagehub现在支持kafka流
https://developer.ibm.com/messaging/2017/06/28/messagehub-now-runs-kafka-0-10-2-1-supports-streams/