MAPREDUCE服务 MRS-基于binlog的MySQL数据同步到MRS集群中:启动Maxwell

时间:2024-07-02 16:39:36

启动Maxwell

  1. 登录Maxwell所在的服务器。
  2. 执行如下命令进入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

  3. 执行如下命令启动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地址。

    显示类似如下信息,表示Maxwell启动成功。

    Success to start Maxwell [78092].

support.huaweicloud.com/cmpntguide-lts-mrs/mrs_01_0441.html