分享

在stormspout的任务开多了会不会影响接收kafka数据呢

在storm端接受kafka数据时,采用的高级的consumer api,就是通过groupid来接收kafka中的数据
如果我spout的任务开多了会不会影响接收kafka数据呢,毕竟多个任务都是用的同一个kafka groupid

已有(2)人评论

跳转到指定楼层
sstutu 发表于 2014-9-15 14:32:47
spout能够接收数据的excutor个数,是由kafka replication的个数决定的
比如你kafka中有两个replication,而在提交topo的时候设置 spout的worknum=5,则你会发现,其中有3个excutor不会接收数据
回复

使用道具 举报

nettman 发表于 2014-9-15 14:36:02
好像partition有关系
比如说我分了3个partition,我就只能启动3个spout
或者说我启动多了就没有意义了
回复

使用道具 举报

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

本版积分规则

关闭

推荐上一条 /2 下一条