Py学习  »  Elasticsearch

Kafka Connect ElasticSearch:将消息存储为预定义索引的格式

vivek ranjan • 4 年前 • 232 次点击  

例子:

{"id":"1","firstName":"abc","lastName":"xyz","dob":"12/09/1995","age":"23"}

此消息结构位于Kafka主题中,但我希望在ElasticSearch中对其进行索引,如下所示

{"id":"1","name"{"firstName":"abc","lastName":"xyz"},"dob":"12/09/1995","age":"23"}

我怎样才能做到这一点?

Python社区是高质量的Python/Django开发社区
本文地址:http://www.python88.com/topic/37964
 
232 次点击  
文章 [ 1 ]  |  最新文章 4 年前