ElasticsearchSinkConnector连接Elasticsearch时出现400 Bad Request问题排查

核心问题1：Elasticsearch 9.x 已彻底移除文档类型（Type） #

你的Elasticsearch版本是9.0.2，配置中保留的"type.name": "listing"是无效配置——从ES 7.x开始就已弃用文档类型，8.x强制移除该功能，9.x完全不支持相关参数，这是触发400错误的直接原因。

核心问题2：连接器版本兼容性 #

需确保Confluent Elasticsearch Sink Connector版本与ES 9.x兼容，建议使用Confluent Platform 7.6及以上版本的连接器，该版本开始原生支持ES 9.x。

修正后的连接器配置 #

移除无效的type.name参数，添加ES 9.x适配配置：

{
 "name": "elasticsearch_product_listings_sink",
 "config": {
   "connector.class": "io.confluent.connect.elasticsearch.ElasticsearchSinkConnector",
   "connection.url": "http://host.docker.internal:9200",
   "tasks.max": "1",
   "topics": "mysql-products",
   "key.ignore": "true",
   // ES 9.x 必需：禁用文档类型相关逻辑
   "schema.ignore": "true",
   // 可选：自定义索引名（默认使用topic名，无需可省略）
   "index.name.format": "mysql-products"
 }
}

额外检查项 #

• 确认本地ES允许跨网络访问：修改elasticsearch.yml中的network.host为0.0.0.0或你的本地IP，避免仅绑定localhost导致Docker容器无法正常通信。
• 检查ES安全设置：如果ES开启了身份验证，需在连接器配置中添加connection.username和connection.password参数。
• 查看ES详细错误日志：访问http://localhost:9200/mysql-products或查看ES本地日志文件logs/elasticsearch.log，可获取更具体的400错误细节，比如索引命名违规、字段映射冲突等。

内容的提问来源于stack exchange，提问作者walruz