简单的storm demo
用storm接收Kafka发送的信息,简单过滤后重新发给Kafka
NetworkReceiveBolt--storm接收信息类
NetworkFormatBolt--storm信息过滤处理类(切分,处理都在这个类里)
TopologyDriver--storm启动类
| Name | Name | Last commit date | ||
|---|---|---|---|---|
简单的storm demo
用storm接收Kafka发送的信息,简单过滤后重新发给Kafka
NetworkReceiveBolt--storm接收信息类
NetworkFormatBolt--storm信息过滤处理类(切分,处理都在这个类里)
TopologyDriver--storm启动类