| ... | ... | @@ -45,4 +45,16 @@ INSERT INTO maxwell.tables (id, schema_id, database_id, name, charset, pk) VALUE |
|
|
|
处理方法：
|
|
|
|
目前比较可行的方法是调大kafka.max.request.size=5242880
|
|
|
|
kafka.buffer.memory=5242880这两个参数，使数据尽量不落地磁盘
|
|
|
|
```
|
|
|
|
|
|
|
|
## com.zendesk.maxwell.schema.ddl.InvalidSchemaError: Couldn't find table 'XXX' in database XXX
|
|
|
|
|
|
|
|
```
|
|
|
|
该问题目前分析有两种可能引起：
|
|
|
|
1. maxwell所配账号无权限访问对应表，导致初始化时在schema中未有该库表结构。
|
|
|
|
处理方法：在maxwell元数据库中手动配置对应schema、库、表
|
|
|
|
2. 对应mysql实例在maxwell元数据库中有多套不同server_id的schema，binlog的server_id变更或重启maxwell引起启动时选择了另一个server_id。
|
|
|
|
处理方法：多次重启至选择目标server_id（不建议）；
|
|
|
|
或者将库中除目标server_id对应的schema外的多份schema和库表全部清除，然后重启至选择目标server_id（可行，不推荐）；
|
|
|
|
或者将对应mysql实例在maxwell元数据库中所有的schema清除，但是记得记录down掉时的binlog的position，然后启动maxwell，后停止修改binlog的position的之前记录的位置，再启动maxwell，如果有已存在的表或者不存在的表再手动补充即可
|
|
|
|
``` |
|
|
\ No newline at end of file |
