Apache Storm 流格式

Question

我是 Apache Storm 的新手，但我当然知道其目的是处理流数据。我的问题是：“流”的要求是什么，以便 Storm 可以使用新芽对其进行处理？ 在我的例子中，我有一个用 C++ 编写的应用程序，我想扩展它以生成可以从 Storm 读取的流数据。但是我该如何开始呢，如何为我的应用程序创建一个界面以及流应该是什么样子？

感谢您的帮助

Answer 1

如您所知，Storm 有 spout 的概念，它从某个源读取数据并将元组流发送到它的 bolts。可以将 spout 写入以任何形式读取任何内容，由您决定。现在有一个从 Kafka 服务器读取的官方实现，但是您可以编写一些从数据库、文件或网络连接中获取数据的东西，只要您实现它。

在 spout 和 bolts 之间，数据可以以任何形式传递：基本类型、字符串、对象、字节数组。