我在Storm工作并开发了一个基本程序,它使用本地文本文件作为输入源.但现在我必须处理来自外部系统的流数据.为此,卡夫卡是最佳选择.
问题是如何让我的Spout从Kafka获取流数据.或者如何将Storm与Kafka集成.我怎么能这样做,所以我可以处理来自Kafka的数据？
cloud streaming apache-kafka apache-storm
apache-kafka ×1
apache-storm ×1
cloud ×1
streaming ×1