在本教程中，我们将学习如何创建一个SAC自定义小部件，用Kafka向NodeJS应用程序发送消息。在上一个教程中，大数据包括，怎么查看大数据，我们讨论了如何使用RabbitMQ实现相同的功能。

Apache Kafka是一个社区分布式事件流平台，每天能够处理数以万亿计的事件。它是为大容量发布-订阅消息和流而设计的，大淘客app，意味着持久、快速和可扩展。Kafka集群不仅具有高度的可伸缩性和容错性，而且与RabbitMQ等其他消息代理相比具有更高的吞吐量。如果您想了解更多关于何时使用Kafka或RabbitMQ的信息，请参阅本博客。

下面是包含以下组件的高级图表：

SAP Analytics Cloud、带有自定义小部件的分析应用程序、SAPUI5组件和套接字.IOJavaScript客户端。Producer–具有套接字.IO图书馆和卡夫卡图书馆。Apache Kafka服务器。消费者-客户端应用程序

下载并在您的机器上安装Kafka服务器。您可以参考本教程如何在Ubuntu机器上安装。

安装并启动服务器后，我们需要创建一个名为SACTopic的主题：~/kafka/bin/卡夫卡-主题.sh--创建--zookeeperlocalhost:2181—复制因子1--分区1--主题让我们测试从命令行向主题发送消息：回音"来自卡夫卡的你好世界"| ~/Kafka/bin/Kafka控制台-制作人.sh--经纪人名单localhost:9092—主题SACTopic>/dev/null并从命令行使用主题中的消息：~/kafka/bin/kafka控制台-消费者.sh--引导服务器localhost:9092—主题主题--从头开始如果没有配置错误，您应该在控制台中看到"来自Kafka的Hello World:

NodeJS服务器充当"生产者"将消息发布到主题。它使用web套接字，套接字.IO在SAC小部件和Kafka之间中继消息。

安装所需的库：

节点服务器.js

在运行服务器之前，将topic变量更新为SACTopic。

使用以下命令运行服务器：

在widget中，我们将使用套接字.IO客户端库并执行到NodeJS服务器的连接，并侦听来自服务器的client\ u数据事件。

onButtonPress（）函数从SAPUI5文本区域获取值，并通过套接字.IO.

客户端应用程序充当"消费者"来阅读来自主题的消息

构建自定义应用程序SAP Analytics Cloud中的小部件，分析应用程序SAP Analytics Cloud自定义小部件，大淘客，用于使用RabbitMQ发送和接收消息github.com/ferrygun/SACKafka

，国内云服务器