atlas如何直接通过kafka传消息创建一些属性,比如业务元数据的属性

atlas如何直接通过kafka传消息创建一些属性,比如业务元数据的属性
之前是想举个例子问,问的是怎么在已拥有的实体类型hive_table里面增加一个行数的属性。思路主要是是通过kafka传数据给atlas。

现在就是想知道我怎么能传kafka数据去给atlas传数据,在atlas端生成一些业务的属性或者标签。

首先感谢朋友看得起,😂😂你要问我这个,我不知道你是不是想问我们之前碰到的情况
alter table tablename add columns(columnname string) ;
就是之前的数据没这一列的会变成NULL,然后数据加这列,会按照指定的分隔符显示再新增加这一列

1、 进入到kafka
2、创建一个初始化数据文件
3、 创建一个topic , testport
4、消费者监听topic , testport
5、另开一个终端窗口,用生产者导入初始化数据文件数据进kafka的 topic, testport ,即可导入
希望能提供一点思路!!!

可参考