2017-02-10 301 views

回答

0

你应该考虑使用Apache storm,这将是非常适合您的需求。

我已经用它和它确实非常好,凝胶像卡夫卡水牛奶。这也很容易实现。

祝你好运

+1

还有很多其他的选择.... –

3

有很多选择你如何能够做到这一点。

卡夫卡的流API是一种可能与你不添加一个新的依赖到项目的优势。就像程序应该这样做一样简单的stream.map(...).to(...)。退房的文档和示例的详细信息:

你甚至可以只使用纯KafkaConsumerKafkaProducer得到这个工作(但使用卡夫卡的流API似乎更比这更自然)。

当然,你也可以使用Apache弗林克,Apache的风暴,阿帕奇顶点,苍鹭(或者Apache的星火)流处理框架 - 肯定的,也有别人了。该程序的写法同上面所描述的一样简单。但是您需要设置一个处理群集来为您的流处理框架部署您的作业。

+0

@anzzý我想知道你为什么恢复接受这个答案吗?你能解释为什么吗? –

相关问题