MAPREDUCE服务 MRS-基于binlog的MySQL数据同步到MRS集群中:启动Maxwell
启动Maxwell
- 登录Maxwell所在的服务器。
- 执行如下命令进入Maxwell安装目录。
cd /opt/maxwell-1.21.0/
如果是初次使用Maxwell,建议将conf/config.properties中的log_level改为debug(调试级别),以便观察启动之后是否能正常从MySQL获取数据并发送到kafka,当整个流程调试通过之后,再把log_level修改为info,然后先停止再启动Maxwell生效。
# log level [debug | info | warn | error]
log_level=debug
- 执行如下命令启动Maxwell。
source /opt/client/bigdata_env
bin/Maxwell
bin/maxwell --user='maxwell' --password='XXXXXX' --host='127.0.0.1' \
--producer=kafka --kafka.bootstrap.servers=kafkahost:9092 --kafka_topic=Maxwell
其中,user,password和host分别表示MySQL的用户名,密码和IP地址,这三个参数可以通过修改配置项配置也可以通过上述命令配置,kafkahost为流式集群的Core节点的IP地址。
命令中如果携带认证密码信息可能存在安全风险,在执行命令前建议关闭系统的history命令记录功能,避免信息泄露。
显示类似如下信息,表示Maxwell启动成功。
Success to start Maxwell [78092].
- MapReduce服务_什么是Kafka_如何使用Kafka
- MapReduce服务_如何使用MapReduce服务_MRS集群客户端安装与使用
- MapReduce服务_什么是MapReduce服务_什么是HBase
- 大数据分析是什么_使用MapReduce_创建MRS服务
- MapReduce服务_什么是HDFS_HDFS特性
- MapReduce服务_什么是ZooKeeper_如何使用ZooKeeper
- MapReduce服务_什么是存算分离_如何配置MRS集群存算分离
- mysql数据库的特点_mysql数据库同步_安装mysql数据库
- MapReduce服务_什么是Yarn_如何使用Yarn
- MapReduce服务_什么是Loader_如何使用Loader