MAPREDUCE服务 MRS-基于binlog的MySQL数据同步到MRS集群中:配置Maxwell
配置Maxwell
在maxwell-XXX文件夹下若有conf目录则配置config.properties文件,配置项说明请参见表1。若没有conf目录,则是在maxwell-XXX文件夹下将config.properties.example修改成config.properties。
配置项 |
是否必填 |
说明 |
默认值 |
---|---|---|---|
user |
是 |
连接MySQL的用户名,即2中新创建的用户 |
- |
password |
是 |
连接MySQL的密码,配置文件中包含认证密码信息可能存在安全风险,建议当前场景执行完毕后删除相关配置文件或加强安全管理。 |
- |
host |
否 |
MySQL地址 |
localhost |
port |
否 |
MySQL端口 |
3306 |
log_level |
否 |
日志打印级别,可选值为
|
info |
output_ddl |
否 |
是否发送DDL(数据库与数据表的定义修改)事件
|
false |
producer |
是 |
生产者类型,配置为kafka
|
stdout |
producer_partition_by |
否 |
分区策略,用来确保相同一类的数据写入到kafka同一分区
|
database |
ignore_producer_error |
否 |
是否忽略生产者发送数据失败的错误
|
true |
metrics_slf4j_interval |
否 |
在日志中输出上传kafka成功与失败数据的数量统计的时间间隔,单位为秒 |
60 |
kafka.bootstrap.servers |
是 |
kafka代理节点地址,配置形式为HOST:PORT[,HOST:PORT] |
- |
kafka_topic |
否 |
写入kafka的topic名称 |
maxwell |
dead_letter_topic |
否 |
当发送某条记录出错时,记录该条出错记录主键的kafka topic |
- |
kafka_version |
否 |
Maxwell使用的kafka producer版本号,不能在config.properties中配置,需要在启动命令时用-- kafka_version xxx参数传入 |
- |
kafka_partition_hash |
否 |
划分kafka topic partition的算法,支持default或murmur3 |
default |
kafka_key_format |
否 |
Kafka record的key生成方式,支持array或Hash |
Hash |
ddl_kafka_topic |
否 |
当output_ddl配置为true时,DDL操作写入的topic |
{kafka_topic} |
filter |
否 |
过滤数据库或表。 |
- |
- MapReduce服务_什么是Kafka_如何使用Kafka
- MapReduce服务_如何使用MapReduce服务_MRS集群客户端安装与使用
- MapReduce服务_什么是存算分离_如何配置MRS集群存算分离
- MapReduce服务_什么是MapReduce服务_什么是HBase
- 大数据分析是什么_使用MapReduce_创建MRS服务
- mysql数据库的特点_mysql数据库同步_安装mysql数据库
- MapReduce服务_什么是HDFS_HDFS特性
- MapReduce服务_什么是Hive_如何使用Hive
- MapReduce服务_什么是Flume_如何使用Flume
- MapReduce工作原理_MapReduce是什么意思_MapReduce流程_MRS_华为云