Bluemix Kafka streams

最新版本的IBM Message Bus是否支持Kafka Streams （此处描述的是...... http://www.confluent.io/blog/introducing-kafka-streams-stream-processing-made-simple/）。有关如何做到这一点的任何示例/示例？ 2 - 如果是的话，是否可以用Node.js的Bluemix Kafka streams

我所试图做的从源数据库（Cloudant） 1.流数据卡夫卡流（BETA服务存在于bluemix连接服务）来完成。使用Kafka流的聚合数据（摘要，计数等） 3. Web仪表板应用程序-frontend（Node.JS，D3.JS）实时使用流并更新仪表板。

谢谢

来源

2016-09-14 Narayana Ishwar

你的意思是IBM MessageHub？ –

嗨汉斯，是的。 IBM Message Hub（在bluemix中） –

你绝对可以发布和如何使用Node.js订阅卡夫卡（又名IBM MessageHub），你可以在各种仪表盘的可视化数据卡夫卡。最近我一直在使用Node-Red，并且使用node-red-dashboard和node-red-contrib-web-worldmap，结果很好。

来自nodejs应用程序的发布/订阅可以通过Confluent REST代理（IBM MessageHub使用）或通过本地node.js客户端完成，就像暴雪在librdkafka顶部写的一样（请参阅https://github.com/blizzard/node-rdkafka）。 Confluent编写了一些nodejs包装函数，以使它更易于使用REST代理（请参见https://github.com/confluentinc/kafka-rest-node）

就Kafka Streams而言，今天支持的主要语言是Java和Scala。您可以将Javascript中的节点客户端与Java中的Streams应用程序混合使用，而不会出现问题Kafka Streams仅作为Java库实现，因此您的流应用程序肯定会在虚拟机或容器中的Bluemix中运行，并且不需要任何其他集群管理器或第三方基础架构。

UPDATE：IBM宣布MessageHub现在支持卡夫卡流

https://developer.ibm.com/messaging/2017/06/28/messagehub-now-runs-kafka-0-10-2-1-supports-streams/

来源

2016-09-15 06:39:00

谢谢Hans。我检查了这个版本，看起来像Bluemix支持Kafka v0,10，它具有流应用程序的功能。是否有任何用Java编写的好例子，我可以使用和尝试。连接到Cloudant的Kafka连接器测试版服务看起来像buggy –

Java中的一些Kafka Streams示例在这里https://github.com/confluentinc/examples –

页面上的示例要求安装confluent和zookeeper。不知道如何在bluemix中运行。 bluemix已经提供了kafka集群，confluent和zookeeper服务不可用。 –

Bluemix Kafka streams

回答

相关问题