1、这一步最主要的细节是将mysql库的所有binlog数据全部打入一个kafka topic，格式使用json。格式如下：这一步的主要的细节在于写入到hdfs的结构，以及为什么不直接写入hive。
成都创新互联不只是一家网站建设的网络公司；我们对营销、技术、服务都有自己独特见解，公司采取“创意+综合+营销”一体化的方式为您提供更专业的服务！我们经历的每一步也许不一定是最完美的，但每一步都有值得深思的意义。我们珍视每一份信任，关注我们的网站制作、成都网站制作质量和服务品质，在得到用户满意的同时，也能得到同行业的专业认可，能够为行业创新发展助力。未来将继续专注于技术创新，服务升级，满足企业一站式成都全网营销推广需求，让再小的品牌网站建设也能产生价值！
2、想问下原来数据库中的数据会不会有更新和删除，如果有的话，想实时同步到hive中很难。另外即使能实时同步到hive中，hive中分析查询也速度也比较慢的。
3、讲MR输出数据到hive表的location分区目录，然后通过Sql添加分区即可。ALTERTABLEtable_nameADDPARTITION(partCol=value1)locationlocation_path换成自己的表，分区字段和path。
1、）数据操作主要分为两大块：一个是全量(将全部数据一次写入到redis)一个是增量（实时更新）这里说的是增量，指的是mysql的update、insert、delate变更数据。2）读取binlog后分析，利用消息队列，推送更新各台的redis缓存数据。
2、二者数据同步的关键在于mysql数据库中主键，方案是在redis启动时区mysql读取所有表键值存入redis中，往redis写数据是，对redis主键自增并进行读取，若mysql更新失败，则需要及时清除缓存及同步redis主键。
3、我们大多倾向于使用这种方式，也就是将数据库中的变化同步到Redis，这种更加可靠。Redis在这里只是做缓存。
同样是两种方法，一种用phpmyadmin（mysql数据库管理）工具，或者mysql命令行。1 用phpmyadmin工具 从控制面板，选择创建的空数据库，点“管理”，进入管理工具页面。
然后点数据源中的+号添加一个数据，数据对象类型选择“数据库导入”，导入MySQL数据库中的产品名称。其他的产品数量和生产日期也是这样操作。
不过值得注意的是，首先需要在数据库链接中设置手动提交，connection.setAutoCommit(false)，然后在执行Statement之后执行connection点抗 mit()。
第一步，把EXCEL数据转换为TXT（记事本）文件 打开EXCEL，全选数据（如果第一行是标题可能不需要），复制，打开记事本，粘贴，保存为一个文件，例如ABC.TXT。
将选中的数据快儿拷贝到一个TXT文本文件中（记得把后面的空格消掉。否则导入数据库后会有对应的空行），假如存到“D：\data.txt”这个位置里。