storm python example利用Python ShellBolts动态处理Kafka消息

本项目允许动态风暴拓扑定义。请参考示例topology.properties文件。使用提供的target/storm-python-example.jar，您可以添加新的Python bolts，而无需重新构建jar。为了让Storm能够将Python脚本作为bolt执行，脚本需要放在/resources目录下的jar中。具体步骤如下：

1. 创建目录：mkdir resources

2. 将脚本移入该目录：mv myBoltScript.py resources/

3. 更新jar文件：jar uf storm-python-example-1.0-SNAPSHOT.jar resources/myBoltScript.py

唯一可用的喷口类型是kafka喷口。当前可用的螺栓类型有：PyBolts（Python bolt）、HBaseBolts、PhoenixBolts和HDFSBolts，需要手动构建。