es-sink.json：
```
{
"name": "es-sink",
"config": {
"connector.class": "io.confluent.connect.elasticsearch.ElasticsearchSinkConnector",
"tasks.max": "2",
"topics": "orders",
"connection.url": "http://es:9200",
"key.ignore": "false",
"write.method": "upsert",
"type.name": "_doc",
"behavior.on.malformed.documents": "ignore",
"schema.ignore": "true",
"max.in.flight.requests": "1",
"flush.timeout.ms": "60000",
"batch.size": "2000",
"max.buffered.records": "20000"
}
}
```
REST 创建与状态：
```
curl -X POST -H "Content-Type: application/json" --data @es-sink.json http://localhost:8083/connectors
curl http://localhost:8083/connectors/es-sink/status
```
投稿
微信公众账号
微信扫一扫加关注
评论 返回
顶部
发表评论 取消回复