是否可以将模型中“attributeDefs”中定义的所有属性发送到 kafka？ 阿帕奇阿特拉斯

编程问答 2022-05-23

问题描述

当我在 Apache Atlas UI 中修改实体时，例如添加分类，Atlas 会向 Kafka 发送通知（通常在 atlas-entities 主题中）。

但是，即使我已在属性定义中将属性“includeInNotification”通知为“true”，我的模型中“entityDefs”中的信息也不会发送到 kakfa。

示例：

许多json模型的片段：

 "entityDefs": [
{
  "category": "ENTITY","serviceType": "spark","name": "spark_db","description": "","typeVersion": "1.0","attributeDefs": [
    {
      "name": "qualifiedname","typeName": "string","isOptional": false,"cardinality": "SINGLE","valuesMinCount": 1,"valuesMaxCount": 1,"isUnique": true,"isIndexable": true,**"includeInNotification": true**
    },{
      "name": "clusterName","isUnique": false,"**includeInNotification": true**
    },...

有人知道怎么做吗？

谢谢

我使用的是 v2.1.0 (EntityNotificationListenerV2)

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

apache-atlas