搜索
搜 索
本版
文章
帖子
用户
图文精华
hadoop-2.6.0+zookeeper-3.4.6+hbase-1.0.0+hive-1.1.0完全分布 ...
首页
Portal
专题
BBS
面试
更多
登录
注册
用户组:游客
主题
帖子
云币
我的帖子
我的收藏
我的好友
我的勋章
设置
退出
导读
淘贴
博客
群组
社区VIP
APP下载
今日排行
本周排行
本周热帖
本月排行
本月热帖
会员排行
About云-梭伦科技
»
专题
›
交流区
›
技术交流
›
Flume
›
疑问解答
›
两个agent消费同一个kafka的topic,输出到各自的文件夹 ...
0
4
0
分享
两个agent消费同一个kafka的topic,输出到各自的文件夹中如何实现?
高兴生活
2018-6-28 14:08:55
发表于
疑问解答
[显示全部楼层]
只看大图
阅读模式
关闭右栏
4
8710
本帖最后由 高兴生活 于 2018-6-28 14:21 编辑
两个agent消费同一个kafka的topic,写入都到各自的hdfs文件夹中如何实现?
补充下,不启用flume的replicating功能,主要考虑最好在kafka那端解决重复消费问题,可靠性高高些。
回复
使用道具
举报
提升卡
置顶卡
沉默卡
喧嚣卡
变色卡
千斤顶
显身卡
已有(4)人评论
电梯直达
正序浏览
yuwenge
发表于 2018-6-28 15:54:26
回帖奖励
+10
云币
是flume与kafka整合??
创建两个消费者组即可解决,两个组消费互不影响。
如下图:
回复
使用道具
举报
显身卡
高兴生活
发表于 2018-6-28 16:05:33
你好 我说的是 具体的实现 是在kafka那端修改consumer.properties中的group.id,这个group.id可以配置几个,多个id用空格隔开么?
在flume那端agent配置kafka.consumer.group.id,填写和上面提到的group.id一致?
回复
使用道具
举报
显身卡
高兴生活
发表于 2018-6-28 19:51:56
问题解决 和我设想描述的一样
回复
使用道具
举报
显身卡
liuyou2036
发表于 2020-7-17 10:37:23
不明觉厉
回复
使用道具
举报
显身卡
还有一些帖子被系统自动隐藏,点此展开
高级模式
B
Color
Image
Link
Quote
Code
Smilies
您需要登录后才可以回帖
登录
|
立即注册
本版积分规则
发表回复
回帖后跳转到最后一页
发表新帖
高兴生活
中级会员
关注
5
主题
20
帖子
5
粉丝
TA的主题
两个agent消费同一个kafka的topic,输出到各自的文件夹中如何实现?
2018-6-28
OpenTsdb写热点如何解决
2017-10-26
询问,clouderamanager相应的健康数据目录,多久自动清理?
2017-7-3
oozie启动失败 提示找不到tomcat bin下的setclasspath.sh
2017-5-10
oozie启动失败
2016-6-5
24小时热文
Spark机器学习
Spark机器学习算法、源码及实战详解
《深度实践Spark机器学习(吴茂贵)》高清
《Spark机器学习第2版》高清中文PDF
像高手一样发言:七种常见工作场景的说话之
关闭
推荐
/2
中文版ChatGPT
1.无需魔法 2.提高编程效率 3.提高文档能力
查看 »
新手帮助
新手帮助:注册遇到问题,领取资源,加入铁粉群,不会使用搜索,如何获取积分等
查看 »
意见
反馈