You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@atlas.apache.org by Jo MailingList <jo...@gmail.com> on 2017/12/20 09:53:18 UTC
Problems publishing messages to ATLAS_HOOK
Hello,
I am new to Atlas and I have been trying to communicate with it through
Kafka.
When I create entities throught Atlas Web UI I see the event notifications
published under the ATLAS_ENTITIES topic.
However, I try to publish an ENTITY_CREATE message as shown in the
Technical User Guide to the ATLAS_HOOK topic and no entity is created and
no event is triggered under the ATLAS_ENTITIES HOOK.
I use : ./kafka-console-producer.sh --broker-list localhost:9027 --topic
ATLAS_HOOK
The message I publish is of the form:
{"version": {"version": "1.0.0"},"message": {"entities": [{"jsonClass":
"org.apache.atlas.typesystem.json.InstanceSerialization$_Reference","id":
{"jsonClass":
"org.apache.atlas.typesystem.json.InstanceSerialization$_Id","id":
"-1467290565135246000","version": 0,"typeName": "hbase_table","state":
"ACTIVE"},"typeName": "hbase_table","values": {"qualifiedName":
"TEST","description": "testing","name": "TEST"},"ClassificationNames":
[],"Classifications": {}}],"type": "ENTITY_CREATE","user": "admin"}}
I have tried to send it as a one line message and also to structure it as a
json file with its indentation but nothing seems to work.
Could you please provide some help on what I might be doing wrong?
Thank you very much,
Best regards
Fwd: Problems publishing messages to ATLAS_HOOK
Posted by Jo MailingList <jo...@gmail.com>.
Hello,
Sorry for disturbing, I already found the problem, missing attributes for
the enity to be created.
Thank you very much
---------- Forwarded message ----------
From: Jo MailingList <jo...@gmail.com>
Date: 2017-12-20 10:53 GMT+01:00
Subject: Problems publishing messages to ATLAS_HOOK
To: user@atlas.apache.org
Hello,
I am new to Atlas and I have been trying to communicate with it through
Kafka.
When I create entities throught Atlas Web UI I see the event notifications
published under the ATLAS_ENTITIES topic.
However, I try to publish an ENTITY_CREATE message as shown in the
Technical User Guide to the ATLAS_HOOK topic and no entity is created and
no event is triggered under the ATLAS_ENTITIES HOOK.
I use : ./kafka-console-producer.sh --broker-list localhost:9027 --topic
ATLAS_HOOK
The message I publish is of the form:
{"version": {"version": "1.0.0"},"message": {"entities": [{"jsonClass":
"org.apache.atlas.typesystem.json.InstanceSerialization$_Reference","id":
{"jsonClass": "org.apache.atlas.typesystem.json.InstanceSerialization$_Id","id":
"-1467290565135246000","version": 0,"typeName": "hbase_table","state":
"ACTIVE"},"typeName": "hbase_table","values": {"qualifiedName":
"TEST","description": "testing","name": "TEST"},"ClassificationNames":
[],"Classifications": {}}],"type": "ENTITY_CREATE","user": "admin"}}
I have tried to send it as a one line message and also to structure it as a
json file with its indentation but nothing seems to work.
Could you please provide some help on what I might be doing wrong?
Thank you very much,
Best regards