分享

kafkaSpout怎么定向发送消息

caiyifeng 发表于 2015-3-16 20:50:09 [显示全部楼层] 回帖奖励 阅读模式 关闭右栏 1 18671
请教各位高手,我定义了一个topology,是通过kafkaspout来抽取消息的,后面有2个bolt进行消息处理,请问又没办法做到:
spout 发出的消息可指定到同一bolt进行处理,就像bolt发送给下一个bolt时,可指定filed一样

已有(1)人评论

跳转到指定楼层
nextuser 发表于 2015-3-16 21:27:53
本帖最后由 pig2 于 2015-3-16 21:29 编辑

这个不需要的
在Topology定义时,需要为每个Bolt指定接收什么样的Stream作为其输入。
也就说无论是spout怎么发,都会发到指定的bolt。
这时候spout在指定就有些多余了,blot自己已经在过滤了。

stream grouping:
所以只要定义FiledGrouping就可以了,在bolt里就过滤出来了。


如下图:spout在发出的时候,bolt自动过滤



更多参考:
storm 入门原理介绍

回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

关闭

推荐上一条 /2 下一条