...
"tasks.max": 1
}
}'
Ex:-
curl -X POST \
httphttp://kafka-connect.kafka-cluster:8083/connectors/ \
-H 'Content-Type: application/json' \
-H 'Cookie: SESSIONID=f1349448-761e-4ebc-a8bb-f6799e756185' \
-H 'Postman-Token: adabf0e8-0599-4ac9-a591-920586ff4d50' \
-H 'cache-control: no-cache' \
-d '{
"name": "cms-case-es-sink28",
"config": {
| Code Block |
|---|
...
"connector.class": "io.confluent.connect.elasticsearch.ElasticsearchSinkConnector", |
...
"connection.url": " |
...
<http://elasticsearch-data-v1.es-cluster:9200", |
...
> "type.name": "general", |
...
"topics": "property-services-enriched", |
...
"key.ignore": "false", |
...
"schema.ignore": true, |
...
"value.converter.schemas.enable": false, |
...
"key.converter": "org.apache.kafka.connect.storage.StringConverter", |
...
"value.converter": "org.apache.kafka.connect.json.JsonConverter", |
...
"transforms": "TopicNameRouter", |
...
"transforms.TopicNameRouter.type": "org.apache.kafka.connect.transforms.RegexRouter", |
...
"transforms.TopicNameRouter.regex": ".*", |
...
"transforms.TopicNameRouter.replacement": "property-services", |
...
"batch.size": 10, |
...
"max.buffered.records": 500, |
...
"flush.timeout.ms": 600000, |
...
"retry.backoff.ms": 5000, |
...
"read.timout.ms": 10000, |
...
"linger.ms": 100, |
...
"max.in.flight.requests": 2, |
...
"errors.log.enable": true, |
...
"errors.deadletterqueue.topic.name": "property-services-es-failed", |
...
"tasks.max": 1 |
}
}'