ex-ug-import-from-kafka.md 文档中没有介绍kafa中数据的格式

已经按照文档操作了hive2nebula ,mysql2nebula,到kafak2nebula时发现ex-ug-import-from-kafka.md 文档中没有介绍kafa中数据的格式.。请问能说一下kafka数据格式吗?或者详细的介绍一下如何在kafka造数据

1赞

@lzy

kafka是读取其他数据源的数据,例如读取mysql的,通过topic形式存储,
topic字段通常如下。

mysql的数据存储在value字段内,是json格式,例如:
image

所以您可以根据需要导入kafka的数据,配置文件里需要关注的是
fields: [xx,xx,…] //对应kafka里的各个字段,例如key、value、offset
nebula.fields: [xx,xx,…] //对应Nebula Graph的图空间的Schema,例如name、age

如何造数据就是创建topic并订阅数据源,可以参考kafka官网

1赞

浙ICP备20010487号