尝试使用Kafka Connect在Elasticsearch中为Kafka主题编制索引

如果您的来源是bigint，那么大概是一个时代。如果是一个纪元，那么这将不起作用：

"mapping": {      "type": "date",      "format": "yyyy-MM-dd HH:mm:ss"        }

因为您要告诉Elasticsearch日期格式为

yyyy-MM-dd HH:mm:ss

因此，请尝试以下操作（暂时省略您的自定义映射；先使它工作，然后再添加回去）：

{  "index_patterns": "exchange*",  "settings": {    "number_of_shards": 1,    "number_of_replicas": 0  },  "mappings": {    "kafka-connect": {      "dynamic_templates": [        {          "dates": { "match": "TIME", "mapping": {   "type": "date" } } } ] } } }

另请参阅：https : //www.elastic.co/guide/zh-
CN/elasticsearch/reference/current/dynamic-field-mapping.html#date-
detection

没有东西被索引到elasticsearch。

检查Kafka Connect工作程序日志和Elasticsearch日志是否有任何错误。