I want to change name of index that has been already created by kafka-connect as a whatever I want.
Here my kafka connector configuration ;
curl --location --request POST 'localhost:8084/connectors' --header 'Content-Type: application/json' --data-raw '
{
"name": "PROXY_HTTP_TRACE",
"config": {
"connector.class": "io.confluent.connect.elasticsearch.ElasticsearchSinkConnector",
"tasks.max": "1",
"key.ignore": "true",
"schema.ignore": "true",
"key.converter": "org.apache.kafka.connect.storage.StringConverter",
"key.converter.schemas.enable": "false",
"value.converter": "org.apache.kafka.connect.json.JsonConverter",
"value.converter.schemas.enable": "false",
"connection.url": "http://localhost:9200",
"connection.username" :"elastic",
"connection.password":"password",
"type.name": "_doc",
"name": "PROXY_HTTP_TRACE",
"topics": "PROXY_HTTP_TRACE",
"transforms":"dropPrefix,routeTS",
"transforms.dropPrefix.type":"org.apache.kafka.connect.transforms.RegexRouter",
"transforms.dropPrefix.regex":"(.*)",
"transforms.dropPrefix.replacement":"$1",
"transforms.routeTS.type":"org.apache.kafka.connect.transforms.TimestampRouter",
"transforms.routeTS.topic.format":"kafka-${topic}-${timestamp}",
"transforms.routeTS.timestamp.format":"YYYYMM"
}
}'
If you can't change the connector configuration you can use elasticsearch ingest pipeline to manipulate the incoming data.