1

我正在 Confluent.Cloud(Kafka) 和 Elastic Cloud 之间创建接收器连接器

我在那里添加了以下详细信息，

{
    "name": "ElasticsearchSinkConnector_1",
    "config": {
    "topics": "sinktest",
    "input.data.format": "AVRO",
    "connector.class": "ElasticsearchSink",
    "name": "ElasticsearchSinkConnector_1",
    "connection.url": "https://enterprise-search-deployment-327352.es.eastus2.azure.elastic-cloud.com:9243",
    "connection.username": "xxxxxxxxxxxxxxxxxx",
    "connection.password": "******",
    "type.name": "_doc",
    "tasks.max": "1"
  }
}

但是，最后，我得到了以下错误，

Failed. Connector was unable to create the specified index. Please check your permissions and verify the configured elastic server is healthy

对于elasticsearch，我在Elastic.Cloud https://enterprise-search-deployment-327352.es.eastus2.azure.elastic-cloud.com:9243中创建了测试帐户

你能帮我解决这个问题吗？我需要在 Elastic cloud 和 confluent.cloud 中添加任何权限吗？

4

1 回答 1

0

我以前也遇到过同样的问题。确保您的 Confluent 集群与您的弹性云位于同一区域 (eastus2)。

于 2021-11-09T17:47:04.503 回答