在 Confluent.Cloud(Kafka) 到 Elastic Cloud 之间创建 Elastic Sink 连接器答案

【问题标题】：Creating Elastic Sink Connector between Confluent.Cloud(Kafka) to Elastic Cloud在 Confluent.Cloud(Kafka) 到 Elastic Cloud 之间创建 Elastic Sink 连接器
【发布时间】：2021-08-12 23:18:45
【问题描述】：

我正在 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 中添加任何权限吗？

【问题讨论】：

标签： elasticsearch apache-kafka apache-kafka-connect elastic-cloud confluent-cloud

【解决方案1】：

我之前也遇到过同样的问题。确保您的 Confluent 集群与您的 Elastic Cloud 位于同一区域 (eastus2)。

【讨论】：

您的答案可以通过额外的支持信息得到改进。请edit 添加更多详细信息，例如引用或文档，以便其他人可以确认您的答案是正确的。你可以找到更多关于如何写好答案的信息in the help center。