Я пытаюсь опубликовать sh данные из kafka topi c в поиске Elasti c. Я смог опубликовать sh все данные в ES. Однако не удалось опубликовать sh ROWTIME в ES.
{
"name": "elasticsearch_sink",
"config": {
"connector.class": "io.confluent.connect.elasticsearch.ElasticsearchSinkConnector",
"tasks.max": "1",
"topics": "k-connect-status",
"connection.url": "http://docker.for.mac.host.internal:9200",
"type.name": "connectstatus",
"value.converter": "org.apache.kafka.connect.json.JsonConverter",
"key.converter": "org.apache.kafka.connect.storage.StringConverter",
"validate.non.null": "false",
"key.ignore":"false",
"schema.ignore":"true",
"value.converter.schemas.enable": "false"
}
}
JSON DATA in topi c:
{
"ROWTIME":1591743374742,
"ROWKEY":"status-connector-elasticsearch_sink_31",
"state":"RUNNING",
"trace":null,
"worker_id":"connect:8083",
"generation":2
}
Elasti c Результат поиска
{
"_index" : "k-connect-status",
"_type" : "connectstatus",
"_id" : "status-connector-elasticsearch_sink_31",
"_score" : 1.0,
"_source" : {
"generation" : 2,
"trace" : null,
"state" : "RUNNING",
"worker_id" : "connect:8083"
}
}
Есть ли способ опубликовать sh ROWTIME в Elasti c Search.