KStorm在Storm 0.9.3中使用Kafka Spout的示例代码

概述：这是一个示例存储库，展示了如何设置Java项目以使用KafkaSpout，它现在是Storm 0.9.3版本的一部分。在线上其它示例要么过时，要么只展示了如何在本地模式下使用KafkaSpout，或者它们展示了与单独Kafka系统的“集群模式”不相关的内容，甚至可能导致一些混乱，因为它们包含了许多不必要的内容（例如使用了Scala）。这个例子展示“做最简单的事情并且能够正常工作”的思路。正确设置pom.xml文件以确保Storm和Kafka之间不兼容的日志库不会阻碍拓扑执行，是最困难的部分。根据个人经验，这个问题可能让你花费大量时间。因此，这也是最脆弱的部分——它可能会在不同的系统和版本之间产生不兼容问题。本示例拓扑基于P. Taylor Goetz的《Storm》一书第1章的基本字数拓扑示例。该示例包含两个版本：一个使用内存中的SentenceSpout（取自Goetz的示例）来展示如何实现Kafka Spout的集成。