在AWS MSK连接器与kafka-connect-elasticsearch中出现“ERROR 创建客户端以验证连接失败”的错误通常是由于连接配置不正确或Elasticsearch服务不可用引起的。以下是一些可能的解决方法:
{
"name": "elasticsearch-sink",
"config": {
"connector.class": "io.confluent.connect.elasticsearch.ElasticsearchSinkConnector",
"connection.url": "http://elasticsearch-host:9200",
"topics": "my-topic",
"key.converter": "org.apache.kafka.connect.storage.StringConverter",
"value.converter": "org.apache.kafka.connect.json.JsonConverter",
"value.converter.schemas.enable": "false",
"type.name": "kafka-connect",
"key.ignore": "true"
}
}
$ curl http://elasticsearch-host:9200
检查网络连接:如果连接器和Elasticsearch位于不同的网络环境中,确保网络连接是正常的,并且没有任何防火墙或安全组规则阻止连接。
检查Elasticsearch身份验证配置:如果您的Elasticsearch实例启用了身份验证机制(如用户名/密码),请确保在连接器配置中提供了正确的凭证信息。
{
"name": "elasticsearch-sink",
"config": {
"connector.class": "io.confluent.connect.elasticsearch.ElasticsearchSinkConnector",
"connection.url": "http://elasticsearch-host:9200",
"topics": "my-topic",
"key.converter": "org.apache.kafka.connect.storage.StringConverter",
"value.converter": "org.apache.kafka.connect.json.JsonConverter",
"value.converter.schemas.enable": "false",
"type.name": "kafka-connect",
"key.ignore": "true",
"connection.username": "your-username",
"connection.password": "your-password"
}
}
通过检查连接配置、验证Elasticsearch服务状态、检查网络连接、检查身份验证配置以及查看连接器日志,您应该能够解决“ERROR 创建客户端以验证连接失败”错误,并成功连接AWS MSK连接器与kafka-connect-elasticsearch。
上一篇:AWS MSK经纪人配置更新
下一篇:AWS MSK设置广告侦听器