如何解决在 Confluent.Cloud(Kafka) 到 Elastic Cloud 之间创建 Elastic Sink Connector
我正在 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 中添加任何权限吗？
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
