elasticsearch - 带有 ElasticsearchSinkConnector 的 Kafka - 是否可以在连接器中定义数据映射？

Question

我将 Kafka 与以下连接器一起使用connector.class=io.confluent.connect.elasticsearch.ElasticsearchSinkConnector ，以便将数据发送到 ElasticSearch。这种组合已经很好用了。

我的问题：我的环境完全是 dockered，我需要每天多次设置整个系统。每次，我都需要在 ES 上映射每个索引的数据结构，然后才能从 Kafka 发送任何数据。否则，ES 使用了错误的数据类型，我无法在不重新索引的情况下处理数据。遗憾的是，动态映射功能对我来说不够好。现在我使用一个 bash 脚本来设置索引的映射。

我的问题：有没有办法在连接器中设置/定义映射？所以我不需要运行我的 bash 脚本？

标签： elasticsearchapache-kafkamappingconfluent-platform