Flink CDC同步MySQL到Elasticsearch的413错误完整解决方案

问题背景

在使用AWS Kinesis Analytics运行Flink CDC任务，将MySQL数据实时同步到Elasticsearch时，遇到持续的413错误，导致任务反复失败重启。

错误现象

错误日志

ElasticsearchStatusException[Unable to parse response body] ResponseException: method [POST], host [https://your-es-endpoint:443], URI [/_bulk?timeout=1m], status line [HTTP/1.1 413 Request Entity Too Large] {"Message":"Request size exceeded 10485760 bytes"} Task switched from RUNNING to FAILED with failure cause: java.lang.RuntimeException: An error occurred in ElasticsearchSink.

关键信息

• HTTP状态码: 413 Request Entity Too Large
• 限制大小: 10485760 bytes (10 MB)
• 失败位