现在就是想知道我怎么能传kafka数据去给atlas传数据,在atlas端生成一些业务的属性或者标签。
首先感谢朋友看得起,😂😂你要问我这个,我不知道你是不是想问我们之前碰到的情况
alter table tablename add columns(columnname string) ;
就是之前的数据没这一列的会变成NULL,然后数据加这列,会按照指定的分隔符显示再新增加这一列
1、 进入到kafka
2、创建一个初始化数据文件
3、 创建一个topic , testport
4、消费者监听topic , testport
5、另开一个终端窗口,用生产者导入初始化数据文件数据进kafka的 topic, testport ,即可导入
希望能提供一点思路!!!