Kafka Connect - Elasti c поиск - publi sh ROWTIME to Elasti c Поиск - PullRequest
0 голосов
/ 19 июня 2020

Я пытаюсь опубликовать 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.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...