搜索
搜 索
本版
文章
帖子
用户
图文精华
hadoop-2.6.0+zookeeper-3.4.6+hbase-1.0.0+hive-1.1.0完全分布 ...
首页
Portal
专题
BBS
面试
办公|编程助手
更多
登录
注册
用户组:游客
主题
帖子
云币
我的帖子
我的收藏
我的好友
我的勋章
设置
退出
导读
淘贴
博客
群组
社区VIP
APP下载
今日排行
本周排行
本周热帖
本月排行
本月热帖
会员排行
About云-梭伦科技
»
专题
›
技术学习(版主发帖区)
›
大数据学习
›
Sqoop
›
连载型
›
sqoop2系统入门之5:用户指南Kafka 连接器
1
0
1
分享
sqoop2系统入门之5:用户指南Kafka 连接器
sehriff
2017-8-28 00:30:43
发表于
连载型
[显示全部楼层]
阅读模式
关闭右栏
0
9315
问题导读
1.如何使用
Kafka 连接器
?
2.写入kafka的数据是否保证顺序性?
上一篇:
sqoop2系统入门之4:用户指南HDFS 连接器
http://www.aboutyun.com/forum.php?mod=viewthread&tid=22564
目录
用法
配置连接
TO 作业配置
加载器(Loader)
目前,只支持TO作业。
1. 用法
通过创建连接器连接(link)和使用该连接的作业(job)来使用该Kafka连接器。
1.1. 配置连接
配置连接(link)涉及的输入包括:
Input
Type
Description
Example
Broker list
String
必须的。逗号隔开的kafka 服务器。
example.com:10000,example.com:11000
Zookeeper connection
String
必须的。逗号隔开的zookeeper服务器quorum。
/etc/conf/hadoop
1.2. TO 作业配置
与作业配置相关联的FROM作业的输入包括:
Input
Type
Description
Example
topic
String
必须的。要转移到的kafka主题。
my topic
2. 加载器(loader)
在数据加载阶段,每个加载器都直接写数据到Kafka。写入kafka的数据是不保证顺序性的。
相关篇章
sqoop2系统入门之1:用户指南5分钟入门Demo
http://www.aboutyun.com/forum.php?mod=viewthread&tid=22549
sqoop2系统入门之2汇总:用户指南shell命令【可收藏备查】
http://www.aboutyun.com/forum.php?mod=viewthread&tid=22602
sqoop2系统入门之3:用户指南通用JDBC连接器
http://www.aboutyun.com/forum.php?mod=viewthread&tid=22563
sqoop2系统入门之4:用户指南HDFS 连接器
http://www.aboutyun.com/forum.php?mod=viewthread&tid=22564
sqoop2系统入门之5:用户指南Kafka 连接器
http://www.aboutyun.com/forum.php?mod=viewthread&tid=22565
sqoop2系统入门之6之开发指南篇:Sqoop Java 客户端API指南
http://www.aboutyun.com/forum.php?mod=viewthread&tid=22619
sqoop2系统入门之7之开发指南篇:编译Sqoop2源码
http://www.aboutyun.com/forum.php?mod=viewthread&tid=22647
sqoop2系统入门之8之开发指南篇:Sqoop 2开发环境配置
http://www.aboutyun.com/forum.php?mod=viewthread&tid=22659
sqoop2系统入门之9之管理员指南篇:Spoop Tool使用介绍
http://www.aboutyun.com/forum.php?mod=viewthread&tid=22698
sqoop2系统入门之10之管理员指南篇:Spoop2升级
http://www.aboutyun.com/forum.php?mod=viewthread&tid=22705
sqoop2系统入门之11之管理员指南篇:Sqoop安装
http://www.aboutyun.com/forum.php?mod=viewthread&tid=22709
本帖被以下淘专辑推荐:
·
sqoop2系统入门
|
主题: 12, 订阅: 1
回复
使用道具
举报
提升卡
置顶卡
沉默卡
喧嚣卡
变色卡
千斤顶
显身卡
没找到任何评论,期待你打破沉寂
高级模式
B
Color
Image
Link
Quote
Code
Smilies
您需要登录后才可以回帖
登录
|
立即注册
本版积分规则
发表回复
回帖后跳转到最后一页
发表新帖
sehriff
中级会员
关注
13
主题
97
帖子
9
粉丝
TA的主题
spark官网机器学习翻译1:数据类型-基于RDD的API
2017-10-24
在PySpark中定制机器学习算法
2017-10-3
Apache Spark 2.2中基于成本的优化器(CBO)
2017-9-27
马士兵大数据_架构师
2017-9-20
IntelliJ IDEA Scala 插件2017.2版升级说明
2017-9-16
24小时热文
kafka面试题精选
Nebula Flink Connector 在实时 ETL 的实践
Apache Doris 用户案例集
国家电网公司主数据管理系统技术规范
企业的主数据建设方法论与实践
关闭
推荐
/2
中文版ChatGPT
1.无需魔法 2.提高编程效率 3.提高文档能力
查看 »
新手帮助
新手帮助:注册遇到问题,领取资源,加入铁粉群,不会使用搜索,如何获取积分等
查看 »
意见
反馈