loghub学习记录
公司前期的数据在Loghub上,现在因业务扩展需要将数据导到kafka上具体的流程:也可以用Kafkabolt向kafka特定的topic写数据,但是要注意需要用阿里云上loghub的storm消费loghub的例子,例子里面会有一个sampleBolt,这个bolt不能省略,这是因为在loghub-spout中,项目人员封装了tuple,所以必须要按项
·
公司前期的数据在Loghub上,现在因业务扩展需要将数据导到kafka上
具体的流程:
也可以用Kafkabolt向kafka特定的topic写数据,但是要注意需要用阿里云上loghub的storm消费loghub的例子,
例子里面会有一个sampleBolt,这个bolt不能省略,这是因为在loghub-spout中,项目人员封装了tuple,所以
必须要按项目的方式去获取tuple,然后通过一层kafkabolt向kafka写数据。
更多推荐


所有评论(0)