请教个问题,为什么storm加了任务后,开始运行特别快,然后越来越慢,然后就停止了,再然后爆出kafka连接失败,然后任务停止,等一会,又启动,又是快速处理,我确认kakfa中日志根本没有读完
而且,每次重启任务的时候,offset都是从start开始读
请教个问题,为什么storm加了任务后,开始运行特别快,然后越来越慢,然后就停止了,再然后爆出kafka连接失败,然后任务停止,等一会,又启动,又是快速处理,我确认kakfa中日志根本没有读完
而且,每次重启任务的时候,offset都是从start开始读